shivaam commented on code in PR #64939:
URL: https://github.com/apache/airflow/pull/64939#discussion_r3074717785
##########
airflow-core/tests/unit/models/test_backfill.py:
##########
@@ -386,6 +386,155 @@ def test_reprocess_behavior(reprocess_behavior, num_in_b,
exc_reasons, dag_maker
assert all(x.state == DagRunState.QUEUED for x in dag_runs_in_b)
[email protected](
+ "reprocess_behavior",
+ [ReprocessBehavior.FAILED, ReprocessBehavior.COMPLETED],
+)
+def test_backfill_conf_overrides_existing_dag_run(reprocess_behavior,
dag_maker, session):
+ """When reprocessing an existing DagRun, the backfill's dag_run_conf
should override the existing conf."""
+ with dag_maker(schedule="@daily") as dag:
+ PythonOperator(task_id="hi", python_callable=print)
+
+ existing_date = "2021-01-03"
+ dag_maker.create_dagrun(
+ run_id=f"scheduled_{existing_date}",
+ logical_date=timezone.parse(existing_date),
+ session=session,
+ state="failed",
Review Comment:
Matches existing pattern in the file — test_reprocess_behavior uses
state="failed" strings. Consistent with the file.
--
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]
