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 cc9308c710 Reraise exception from strict dataset URI checks (#39719)
     add 4ee46b984d Remove `openlineage.common` dependencies in Google and 
Snowflake providers. (#39614)

No new revisions were added by this update.

Summary of changes:
 .../cloud/openlineage/BigQueryErrorRunFacet.json   |  30 ++
 .../cloud/openlineage/BigQueryJobRunFacet.json     |  37 ++
 .../google/cloud/openlineage}/__init__.py          |   0
 .../providers/google/cloud/openlineage/utils.py    | 392 +++++++++++++++++++++
 .../providers/google/cloud/operators/bigquery.py   |  63 +---
 .../google/cloud/transfers/bigquery_to_gcs.py      |   2 +-
 .../google/cloud/transfers/gcs_to_bigquery.py      |   2 +-
 .../providers/google/cloud/utils/openlineage.py    |  81 -----
 airflow/providers/openlineage/utils/utils.py       |  11 +-
 airflow/providers/snowflake/hooks/snowflake.py     |   5 +-
 airflow/providers/snowflake/utils/openlineage.py   |  63 ++++
 .../google/cloud/openlineage}/__init__.py          |   0
 .../google/cloud/openlineage/test_utils.py         | 369 +++++++++++++++++++
 .../google/cloud/operators/test_bigquery.py        |  15 +-
 .../cloud/{operators => utils}/job_details.json    |   0
 .../google/cloud/utils/out_table_details.json      |  30 ++
 .../google/cloud/utils/script_job_details.json     |  36 ++
 .../google/cloud/utils/table_details.json          |  53 +++
 .../google/cloud/utils/test_openlineage.py         | 142 --------
 tests/providers/openlineage/utils/test_sql.py      |  11 -
 .../providers/snowflake/utils/test_openlineage.py  |  62 ++++
 21 files changed, 1093 insertions(+), 311 deletions(-)
 create mode 100644 
airflow/providers/google/cloud/openlineage/BigQueryErrorRunFacet.json
 create mode 100644 
airflow/providers/google/cloud/openlineage/BigQueryJobRunFacet.json
 copy airflow/{api_connexion => providers/google/cloud/openlineage}/__init__.py 
(100%)
 create mode 100644 airflow/providers/google/cloud/openlineage/utils.py
 delete mode 100644 airflow/providers/google/cloud/utils/openlineage.py
 create mode 100644 airflow/providers/snowflake/utils/openlineage.py
 copy {airflow/api_connexion => 
tests/providers/google/cloud/openlineage}/__init__.py (100%)
 create mode 100644 tests/providers/google/cloud/openlineage/test_utils.py
 rename tests/providers/google/cloud/{operators => utils}/job_details.json 
(100%)
 create mode 100644 tests/providers/google/cloud/utils/out_table_details.json
 create mode 100644 tests/providers/google/cloud/utils/script_job_details.json
 create mode 100644 tests/providers/google/cloud/utils/table_details.json
 delete mode 100644 tests/providers/google/cloud/utils/test_openlineage.py
 create mode 100644 tests/providers/snowflake/utils/test_openlineage.py

Reply via email to