0.16.1 - 2022-11-03
Added
- Airflow: add
dag_runinformation to Airflow version run facet#1133@fm100
Adds the Airflow DAG run ID to thetaskInfofacet, making this additional information available to the integration. - Airflow: add
LoggingMixinto extractors#1149@JDarDagran
Adds aLoggingMixinclass to the custom extractor to make the output consistent with general Airflow and OpenLineage logging settings. - Airflow: add default extractor
#1162@mobuchowski
Adds aDefaultExtractorto support the default implementation of OpenLineage for external operators without the need for custom extractors. - Airflow: add
on_completeargument inDefaultExtractor#1188@JDarDagran
Adds support for running another method onextract_on_complete. - SQL: reorganize the library into multiple packages
#1167@StarostaGit @mobuchowski
Splits the SQL library into a Rust implementation and foreign language bindings, easing the process of adding language interfaces. Also contains CI fix.
Changed
- Airflow: move
get_connection_urias extractor's classmethod#1169@JDarDagran
Theget_connection_urimethod allowed for too many params, resulting in unnecessarily long URIs. This changes the logic to whitelisting per extractor. - Airflow: change
get_openlineage_facets_on_start/completebehavior#1201@JDarDagran
Splits up the method for greater legibility and easier maintenance.
Fixed
- Airflow: always send SQL in
SqlJobFacetas a string#1143@mobuchowski
Changes the data type ofqueryfrom array to string to an fix error in theRedshiftSQLOperator. - Airflow: include
__extra__case when filtering URI query params#1144@JDarDagran
Includes theconn.EXTRA_KEYin theget_connection_urimethod to avoid exposing secrets in URIs via the__extra__key. - Airflow: enforce column casing in
SQLCheckExtractors#1159@denimalpaca
Uses the parent extractor's_is_uppercase_namesproperty to determine if the column should be upper cased in theSQLColumnCheckExtractor's_get_input_facets()method. - Spark: prevent exception when no schema provided
#1180@pawel-big-lebowski
Prevents evaluation of column lineage when theschemaFacetisnull. - Great Expectations: add V3 API compatibility
#1194@denimalpaca
Fixes the Pandas datasource to make it V3 API-compatible.
Removed
- Airflow: remove support for Airflow 1.10
#1128@mobuchowski
Removes the code structures and tests enabling support for Airflow 1.10.