diff --git a/airflow/providers/openlineage/plugins/listener.py b/airflow/providers/openlineage/plugins/listener.py index fbe50e4a728a5..9c568aa374196 100644 --- a/airflow/providers/openlineage/plugins/listener.py +++ b/airflow/providers/openlineage/plugins/listener.py @@ -439,7 +439,6 @@ def on_dag_run_running(self, dag_run: DagRun, msg: str) -> None: self.submit_callable( self.adapter.dag_started, dag_id=dag_run.dag_id, - run_id=dag_run.run_id, logical_date=dag_run.logical_date, start_date=dag_run.start_date, nominal_start_time=data_interval_start,