Spaces:
Running
Running
Yaron Koresh
commited on
Update app.py
Browse files
app.py
CHANGED
@@ -10,9 +10,9 @@ import numpy as np
|
|
10 |
from lxml.html import fromstring
|
11 |
#from transformers import pipeline
|
12 |
from torch import multiprocessing as mp
|
13 |
-
from torch.multiprocessing import Pool as Pool
|
14 |
#from pathos.multiprocessing import ProcessPool as Pool
|
15 |
-
|
16 |
#from diffusers.pipelines.flux import FluxPipeline
|
17 |
#from diffusers.utils import export_to_gif
|
18 |
#from huggingface_hub import hf_hub_download
|
@@ -181,7 +181,7 @@ def run(p1,p2,*result):
|
|
181 |
rng = list(range(ln))
|
182 |
|
183 |
arr = [p for _ in rng]
|
184 |
-
pool = Pool(
|
185 |
out = list(pool.imap(infer,arr))
|
186 |
pool.close()
|
187 |
pool.join()
|
|
|
10 |
from lxml.html import fromstring
|
11 |
#from transformers import pipeline
|
12 |
from torch import multiprocessing as mp
|
13 |
+
#from torch.multiprocessing import Pool as Pool
|
14 |
#from pathos.multiprocessing import ProcessPool as Pool
|
15 |
+
from pathos.threading import ThreadPool as Pool
|
16 |
#from diffusers.pipelines.flux import FluxPipeline
|
17 |
#from diffusers.utils import export_to_gif
|
18 |
#from huggingface_hub import hf_hub_download
|
|
|
181 |
rng = list(range(ln))
|
182 |
|
183 |
arr = [p for _ in rng]
|
184 |
+
pool = Pool()
|
185 |
out = list(pool.imap(infer,arr))
|
186 |
pool.close()
|
187 |
pool.join()
|