shivaam commented on code in PR #67381:
URL: https://github.com/apache/airflow/pull/67381#discussion_r3293277112
##########
airflow-core/src/airflow/api_fastapi/core_api/routes/public/backfills.py:
##########
@@ -112,6 +113,43 @@ def get_backfill(
raise HTTPException(status.HTTP_404_NOT_FOUND, "Backfill not found")
+@backfills_router.get(
+ path="/{backfill_id}/dag_runs",
+ responses=create_openapi_http_exception_doc([status.HTTP_404_NOT_FOUND]),
+ dependencies=[
+ Depends(requires_access_backfill(method="GET")),
+ ],
+)
+def list_backfill_dag_runs(
+ backfill_id: NonNegativeInt,
+ limit: QueryLimit,
+ offset: QueryOffset,
+ order_by: Annotated[
+ SortParam,
+ Depends(SortParam(["id", "sort_ordinal"],
BackfillDagRun).dynamic_depends(default="sort_ordinal")),
+ ],
+ session: SessionDep,
+) -> BackfillDagRunCollectionResponse:
+ """List Dag runs associated with a backfill, including skipped slots."""
+ backfill = session.get(Backfill, backfill_id)
+ if not backfill:
+ raise HTTPException(status.HTTP_404_NOT_FOUND, f"Backfill with id
{backfill_id} not found")
+
+ select_stmt, total_entries = paginated_select(
+ statement=select(BackfillDagRun)
+ .where(BackfillDagRun.backfill_id == backfill_id)
+ .options(joinedload(BackfillDagRun.dag_run)),
Review Comment:
`joinedload` issues a LEFT OUTER JOIN, preserving rows where dag_run_id is
NULL (skipped slots).
--
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]
