Spaces:
Sleeping
Sleeping
Yaron Koresh
commited on
Update app.py
Browse files
app.py
CHANGED
@@ -241,7 +241,8 @@ def parallel(timeout,*pairs):
|
|
241 |
return
|
242 |
if len(pairs) == 1:
|
243 |
pairs = pairs[0]
|
244 |
-
|
|
|
245 |
async def async_main(queue):
|
246 |
while True:
|
247 |
command = await queue.get()
|
@@ -251,7 +252,9 @@ def parallel(timeout,*pairs):
|
|
251 |
for pair in pairs:
|
252 |
f = pair.pop(0)
|
253 |
queue.put(Command(f, pair))
|
254 |
-
|
|
|
|
|
255 |
|
256 |
# functionality
|
257 |
|
|
|
241 |
return
|
242 |
if len(pairs) == 1:
|
243 |
pairs = pairs[0]
|
244 |
+
out = []
|
245 |
+
|
246 |
async def async_main(queue):
|
247 |
while True:
|
248 |
command = await queue.get()
|
|
|
252 |
for pair in pairs:
|
253 |
f = pair.pop(0)
|
254 |
queue.put(Command(f, pair))
|
255 |
+
for pair in pairs:
|
256 |
+
out.append(queue.get(timeout=timeout))
|
257 |
+
return out
|
258 |
|
259 |
# functionality
|
260 |
|