Fix fork after task.close() is called (#605)

This commit is contained in:
allegroai 2022-03-15 09:55:57 +02:00
parent 9c93201522
commit d8cb82eab4

View File

@ -85,6 +85,9 @@ class PatchOsFork(object):
from ..task import Task
# force creating a Task
task = Task.current_task()
if task is None:
return ret
# # Hack: now make sure we setup the reporter threads (Log+Reporter)
if not task._report_subprocess_enabled:
BackgroundMonitor.start_all(task=task)