This is an automated email from the ASF dual-hosted git repository.
mobuchowski pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 2d1ea165005 chore: Bump Ol client dependency to 1.46 (#66145)
add 44b79fe5398 feat: add public emit_dataset_lineage and
emit_query_lineage API for OpenLineage provider (#65788)
No new revisions were added by this update.
Summary of changes:
.../airflow/providers/openlineage/api/__init__.py} | 30 +-
.../src/airflow/providers/openlineage/api/core.py | 57 +++
.../airflow/providers/openlineage/api/datasets.py | 173 +++++++++
.../src/airflow/providers/openlineage/api/sql.py | 183 +++++++++
.../providers/openlineage/plugins/adapter.py | 4 +-
.../providers/openlineage/plugins/listener.py | 34 +-
.../openlineage/utils/sql_hook_lineage.py | 91 ++++-
.../airflow/providers/openlineage/utils/utils.py | 201 +++++++++-
.../tests/unit/openlineage/api}/__init__.py | 0
.../tests/unit/openlineage/api/test_core.py | 66 ++++
.../tests/unit/openlineage/api/test_datasets.py | 236 ++++++++++++
.../tests/unit/openlineage/api/test_sql.py | 312 +++++++++++++++
.../openlineage/utils/test_sql_hook_lineage.py | 424 ++++-----------------
.../tests/unit/openlineage/utils/test_utils.py | 218 +++++++++++
14 files changed, 1611 insertions(+), 418 deletions(-)
copy
providers/{apache/iceberg/src/airflow/providers/apache/iceberg/version_compat.py
=> openlineage/src/airflow/providers/openlineage/api/__init__.py} (52%)
create mode 100644
providers/openlineage/src/airflow/providers/openlineage/api/core.py
create mode 100644
providers/openlineage/src/airflow/providers/openlineage/api/datasets.py
create mode 100644
providers/openlineage/src/airflow/providers/openlineage/api/sql.py
copy {airflow-core/src/airflow/_shared =>
providers/openlineage/tests/unit/openlineage/api}/__init__.py (100%)
create mode 100644
providers/openlineage/tests/unit/openlineage/api/test_core.py
create mode 100644
providers/openlineage/tests/unit/openlineage/api/test_datasets.py
create mode 100644 providers/openlineage/tests/unit/openlineage/api/test_sql.py
