exp: follow output on run-all

This commit is contained in:
Peter Rowlands
2022-07-12 21:39:49 +09:00
committed by Peter Rowlands (변기호)
parent acab008c65
commit e8448345f1
+6
View File
@@ -169,6 +169,12 @@ class Experiments:
def reproduce_queued(self, **kwargs):
self.celery_queue.spawn_worker()
# wait for task execution to start
while not first(self.celery_queue.iter_active()):
time.sleep(1)
for entry in self.celery_queue.iter_active():
for line in self.celery_queue.proc.follow(entry.stash_rev):
ui.write(line, end="")
def _log_reproduced(self, revs: Iterable[str], tmp_dir: bool = False):
names = []