This is an automated email from the ASF dual-hosted git repository.
mobuchowski pushed a commit to branch openlineage-execute-in-thread
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/openlineage-execute-in-thread
by this push:
new 562be27275c Regenerate OpenLineage get_provider_info.py with
execute_in_thread config
562be27275c is described below
commit 562be27275cd220d28be5c8e8b85c519aebafbbe
Author: Maciej Obuchowski <[email protected]>
AuthorDate: Thu Jun 18 14:39:04 2026 +0200
Regenerate OpenLineage get_provider_info.py with execute_in_thread config
The update-providers-build-files prek hook regenerates get_provider_info.py
from provider.yaml. Adding execute_in_thread to provider.yaml requires the
generated file to be updated in sync.
Signed-off-by: Maciej Obuchowski <[email protected]>
---
.../src/airflow/providers/openlineage/get_provider_info.py | 7 +++++++
1 file changed, 7 insertions(+)
diff --git
a/providers/openlineage/src/airflow/providers/openlineage/get_provider_info.py
b/providers/openlineage/src/airflow/providers/openlineage/get_provider_info.py
index 60cf1a981a6..d73e8a3106b 100644
---
a/providers/openlineage/src/airflow/providers/openlineage/get_provider_info.py
+++
b/providers/openlineage/src/airflow/providers/openlineage/get_provider_info.py
@@ -106,6 +106,13 @@ def get_provider_info():
"default": "",
"version_added": "1.1.0",
},
+ "execute_in_thread": {
+ "description": "If true, OpenLineage task-level event
emission on the worker runs in a time-bounded\nbackground thread instead of a
forked child process (the default).\n\nThe default fork model duplicates the
task runner process - including its connection to\nthe Airflow supervisor -
into a short-lived child. If the child's event emission blocks\n(for example on
a slow or unreachable lineage backend), the inherited supervisor\nconnection
can be left in a state tha [...]
+ "default": "False",
+ "example": None,
+ "type": "boolean",
+ "version_added": "2.19.0",
+ },
"execution_timeout": {
"description": "Maximum amount of time (in seconds)
that OpenLineage can spend executing metadata extraction for\ntask (on worker).
Note that other configurations, sometimes with higher priority, such
as\n`[core]
task_success_overtime\n<https://airflow.apache.org/docs/apache-airflow/stable/configurations-ref.html#task-success-overtime>`_,\nmay
also affect how much time OpenLineage has for execution.\n",
"default": "10",
