Skip to content

Commit 0ac1549

Browse files
committed
allow queue for macos
1 parent 6643c11 commit 0ac1549

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

src/warnet/deploy.py

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -353,7 +353,11 @@ def deploy_network(directory: Path, debug: bool = False, namespace: Optional[str
353353
for p in processes:
354354
p.join()
355355

356-
if any([queue.get() for _ in range(queue.qsize())]):
356+
drained_items = []
357+
while not queue.empty():
358+
drained_items.append(queue.get())
359+
360+
if any(drained_items):
357361
_run(
358362
scenario_file=SCENARIOS_DIR / "ln_init.py",
359363
debug=True,

0 commit comments

Comments
 (0)