From 794a6644954b677c42219e1c00336ecbb4fe818c Mon Sep 17 00:00:00 2001 From: Kimyen Ladia Date: Wed, 13 Jul 2022 22:44:16 -0700 Subject: [PATCH] monkey patch multiprocessing --- airflow/executors/local_executor.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/airflow/executors/local_executor.py b/airflow/executors/local_executor.py index 7fcba8a6af425..d6133e37e2485 100644 --- a/airflow/executors/local_executor.py +++ b/airflow/executors/local_executor.py @@ -26,6 +26,8 @@ import os import subprocess from abc import abstractmethod +# monkey patch multiprocessing based on https://github.com/apache/airflow/issues/14896 +import billiard as multiprocessing from multiprocessing import Manager, Process from multiprocessing.managers import SyncManager from queue import Empty, Queue # pylint: disable=unused-import # noqa: F401