Kacper Muda
Kacper Muda
After debugging some user issues i feel like we could add some more DEBUG level logs, so that we can deduce more information about what's happening inside OpenLineage. We should...
Remove AirflowMappedTaskRunFacet and UnknownOperatorAttributeRunFacet as they have been deprecated in previous release. --- **^ Add meaningful description above** Read the **[Pull Request Guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#pull-request-guidelines)** for more information. In case of fundamental...
closes: #39467 --- **^ Add meaningful description above** Read the **[Pull Request Guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#pull-request-guidelines)** for more information. In case of fundamental code changes, an Airflow Improvement Proposal ([AIP](https://cwiki.apache.org/confluence/display/AIRFLOW/Airflow+Improvement+Proposals)) is needed. In...
### Description I would like to add a new facet that would allow re-creation of DAG graph from OL events. It could look like in my example, but if anybody...
As discussed [here](https://github.com/apache/airflow/pull/39513#discussion_r1598164584) at pr #39513, changes introduced by #39336 make all previous OpenLineage provider versions incompatible with Airflow >= 2.10.0 (due to changes in try_number behaviour change in core...
Adding a docstring to conf.py describing how we should retrieve OL configuration. Adjusting `dag_state_change_process_pool_size` to match that logic. --- **^ Add meaningful description above** Read the **[Pull Request Guidelines](https://github.com/apache/airflow/blob/main/contributing-docs/05_pull_requests.rst#pull-request-guidelines)** for...
This PR fixes two things: 1. Return value of `BigQueryInsertJobOperator's` `execute_complete()` (so execution in deferrable mode) will now be an actual BQ job id instead of None. As described in...
Removing TaskGroup's tooltip from AirflowJobFacet that's included in DAG start event. The tooltip is already included in task level OpenLineage events and it might be long, so there is no...
I am thinking about adding support for the IDENTIFIER() clause (available in Snowflake and Databricks, see docs below). In OpenLineage, I was able to [partially support it](https://github.com/OpenLineage/OpenLineage/pull/2999) by implementing visitors,...
BigQueryInsertJobOperator already support OpenLineage for QUERY type jobs, but it lacks Column Level Lineage (CLL). This PR introduces CLL (Column-Level Lineage) to this operator based on SQL parsing, which can...