diff --git a/airflow/providers/openlineage/plugins/listener.py b/airflow/providers/openlineage/plugins/listener.py index 25ded6d7f43618..2828f63f2e9d79 100644 --- a/airflow/providers/openlineage/plugins/listener.py +++ b/airflow/providers/openlineage/plugins/listener.py @@ -17,7 +17,7 @@ from __future__ import annotations import logging -from concurrent.futures import ThreadPoolExecutor +from concurrent.futures import ProcessPoolExecutor from datetime import datetime from typing import TYPE_CHECKING @@ -250,7 +250,7 @@ def on_failure(): @property def executor(self): if not self._executor: - self._executor = ThreadPoolExecutor(max_workers=8, thread_name_prefix="openlineage_") + self._executor = ProcessPoolExecutor(max_workers=8) return self._executor @hookimpl