mobuchowski opened a new pull request, #29940: URL: https://github.com/apache/airflow/pull/29940
This PR consistent mostly of code that was created in OpenLineage project. It consists of - Provider wiring - `OpenLineageListener` that uses Listener API to get notification about changes to TaskInstance and Dag states - `Extractor` framework, which is used to extract lineage information from particular operators. It's ment to be replaced by direct implementation of lineage features in later phase. This PR does not include actual extractors, but code around using and registering them. - `OpenLineageAdapter` that translates extracted information to OpenLineage events. - Utils around specific Airflow OL facets and features This is a base implementation that's not ment to be released yet, but to add code modified to be consistent with Airflow standards, get early feedback and provide canvas to add later features, docs, tests on. Closes: #29669 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
