mobuchowski opened a new pull request, #44617: URL: https://github.com/apache/airflow/pull/44617
Right now, when task gets cleared via UI, and dag run gets scheduled again, the OpenLineage integration will emit the event with same OL run_id as in the first execution. This is confusing for OpenLineage consumers, as the run that's already received terminal state should not receive following events. To fix that, use `clear_number` introduced in Airflow 2.8.0 as additional information used in generating OpenLineage's `run_id` to distinguish between those runs. -- 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]
