We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3eb29b8 commit 32cbcb2Copy full SHA for 32cbcb2
terra/executor/process.py
@@ -7,3 +7,11 @@
7
class ProcessPoolExecutor(concurrent.futures.ProcessPoolExecutor,
8
terra.executor.base.BaseExecutor):
9
multiprocess = True
10
+ def __init__(self, *args, **kwargs):
11
+ # Workaround for https://github.com/VisionSystemsInc/terra/issues/115 the
12
+ # simplest workaround was to pre-finalize celery and pre-cache the property
13
+ # app.tasks, as these were the components with locks that were causing
14
+ # deadlocks
15
+ from celery import _state
16
+ _state.get_current_app().tasks
17
+ return super().__init__(*args, **kwargs)
0 commit comments