(airflow) branch main updated: fix: Adjust emits_ol_events to account for inlets check since AF3.0.2 (#53449)

[mobuchowski]

This is an automated email from the ASF dual-hosted git repository.

mobuchowski pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new ebf3fba15b2 fix: Adjust emits_ol_events to account for inlets check 
since AF3.0.2 (#53449)
ebf3fba15b2 is described below

commit ebf3fba15b2f4d2126049aac7357a3456675d1c8
Author: Kacper Muda <mudakac...@gmail.com>
AuthorDate: Thu Jul 17 13:56:35 2025 +0200

    fix: Adjust emits_ol_events to account for inlets check since AF3.0.2 
(#53449)
---
 providers/openlineage/src/airflow/providers/openlineage/utils/utils.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/providers/openlineage/src/airflow/providers/openlineage/utils/utils.py 
b/providers/openlineage/src/airflow/providers/openlineage/utils/utils.py
index bd81879c5c2..2316cd3c13d 100644
--- a/providers/openlineage/src/airflow/providers/openlineage/utils/utils.py
+++ b/providers/openlineage/src/airflow/providers/openlineage/utils/utils.py
@@ -52,7 +52,7 @@ from airflow.providers.openlineage.utils.selective_enable 
import (
     is_dag_lineage_enabled,
     is_task_lineage_enabled,
 )
-from airflow.providers.openlineage.version_compat import AIRFLOW_V_3_0_PLUS
+from airflow.providers.openlineage.version_compat import AIRFLOW_V_3_0_PLUS, 
get_base_airflow_version_tuple
 from airflow.serialization.serialized_objects import SerializedBaseOperator
 from airflow.utils.module_loading import import_string
 
@@ -780,6 +780,7 @@ def _emits_ol_events(task: BaseOperator | MappedOperator) 
-> bool:
             not getattr(task, "on_execute_callback", None),
             not getattr(task, "on_success_callback", None),
             not task.outlets,
+            not (task.inlets and get_base_airflow_version_tuple() >= (3, 0, 
2)),  # Added in 3.0.2 #50773
         )
     )