updated args
This commit is contained in:
parent
ac88e3f832
commit
d3b621dfd2
|
@ -83,7 +83,6 @@ def parallel_apply(modules, inputs, kwargs_tup=None, devices=None):
|
||||||
with lock:
|
with lock:
|
||||||
results[i] = e
|
results[i] = e
|
||||||
|
|
||||||
pdb.set_trace()
|
|
||||||
if len(modules) > 1:
|
if len(modules) > 1:
|
||||||
threads = [threading.Thread(target=_worker,
|
threads = [threading.Thread(target=_worker,
|
||||||
args=(i, module, input, kwargs, device))
|
args=(i, module, input, kwargs, device))
|
||||||
|
@ -97,6 +96,7 @@ def parallel_apply(modules, inputs, kwargs_tup=None, devices=None):
|
||||||
else:
|
else:
|
||||||
_worker(0, modules[0], inputs[0], kwargs_tup[0], devices[0])
|
_worker(0, modules[0], inputs[0], kwargs_tup[0], devices[0])
|
||||||
|
|
||||||
|
pdb.set_trace()
|
||||||
outputs = []
|
outputs = []
|
||||||
for i in range(len(inputs)):
|
for i in range(len(inputs)):
|
||||||
output = results[i]
|
output = results[i]
|
||||||
|
|
Loading…
Reference in New Issue