Skip to content

Commit 7f4fae2

Browse files
fix: also fix hanging error for LocalTaskQueue
1 parent 57aecd4 commit 7f4fae2

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

taskqueue/taskqueue.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -470,6 +470,10 @@ def execute(self, progress=True, parallel=None, total=None):
470470

471471
total = totalfn(self.queue, total)
472472

473+
# Don't fork, spawn entirely new processes. This
474+
# avoids accidental deadlocks.
475+
mp.set_start_method("spawn", force=True)
476+
473477
with tqdm(total=total, desc="Tasks", disable=(not progress)) as pbar:
474478
if self.parallel == 1:
475479
while self.queue:

0 commit comments

Comments
 (0)