(airflow) branch main updated: Fix hll import in openlineage system tests (#69196)

[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 62ca5d9746f Fix hll import in openlineage system tests (#69196)
62ca5d9746f is described below

commit 62ca5d9746fe97474de4cdeb1afe4a936e83874e
Author: Kacper Muda <mudakac...@gmail.com>
AuthorDate: Wed Jul 1 11:11:33 2026 +0200

    Fix hll import in openlineage system tests (#69196)
---
 .../openlineage/example_openlineage_policy_dag_events_false_dag.py    | 2 +-
 .../system/openlineage/example_openlineage_policy_hook_lineage_dag.py | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/providers/openlineage/tests/system/openlineage/example_openlineage_policy_dag_events_false_dag.py
 
b/providers/openlineage/tests/system/openlineage/example_openlineage_policy_dag_events_false_dag.py
index 00342319c52..52d754b3132 100644
--- 
a/providers/openlineage/tests/system/openlineage/example_openlineage_policy_dag_events_false_dag.py
+++ 
b/providers/openlineage/tests/system/openlineage/example_openlineage_policy_dag_events_false_dag.py
@@ -35,7 +35,7 @@ from system.openlineage.operator import 
OpenLineageTestOperator
 
 
 def _register_hook_lineage():
-    from airflow.lineage.hook import get_hook_lineage_collector
+    from airflow.providers.common.compat.lineage.hook import 
get_hook_lineage_collector
 
     collector = get_hook_lineage_collector()
     collector.add_input_asset(context=None, uri="file://host1/in1.txt")
diff --git 
a/providers/openlineage/tests/system/openlineage/example_openlineage_policy_hook_lineage_dag.py
 
b/providers/openlineage/tests/system/openlineage/example_openlineage_policy_hook_lineage_dag.py
index 721672808b8..6f1e8a76f97 100644
--- 
a/providers/openlineage/tests/system/openlineage/example_openlineage_policy_hook_lineage_dag.py
+++ 
b/providers/openlineage/tests/system/openlineage/example_openlineage_policy_hook_lineage_dag.py
@@ -37,7 +37,7 @@ from system.openlineage.operator import 
OpenLineageTestOperator
 
 
 def _register_hook_lineage():
-    from airflow.lineage.hook import get_hook_lineage_collector
+    from airflow.providers.common.compat.lineage.hook import 
get_hook_lineage_collector
 
     collector = get_hook_lineage_collector()
     collector.add_input_asset(context=None, uri="file://host1/in1.txt")
@@ -47,7 +47,7 @@ def _register_hook_lineage():
 
 
 def _register_sql_hook_lineage():
-    from airflow.lineage.hook import get_hook_lineage_collector
+    from airflow.providers.common.compat.lineage.hook import 
get_hook_lineage_collector
     from airflow.providers.common.sql.hooks.lineage import 
SqlJobHookLineageExtra
 
     collector = get_hook_lineage_collector()