Not able to run DreamPropeller

[aplatyps]

Hi, I tried launching the launch_speedup.py but was not able to run any training due to the torch.multiprocessing queue in train_loop() being stuck.

DreamPropeller/launch_speedup.py

Line 298 in d7844af

_preds, _step = queues[1].get()

After looking through the code I found it very odd that items are put into queue[1] in run_workers() but run_workers() is not invoked in run(), therefore when train_loop() tries to get the predicted item from queue[1] it will be stuck indefinitely. I don't understand why is it written that way and not sure how to fix it. May I know if is this design is intended and are you able to run launch_speedup.py without any issues? Thanks.