CM000n commented on issue #70444:
URL: https://github.com/apache/airflow/issues/70444#issuecomment-6035223165
We hit the same gap on Airflow 3.3.1 after reprocessing upstream assets:
partitions that only received part of their required events (e.g. 1/13 or
13/117) stay `pending` forever and the DAG list shows "N pending Dag runs" in
the schedule column, which is misleading. `delete-dag-queued-events` / `DELETE
/dags/{dag_id}/assets/queuedEvents` returns nothing to delete since
`AssetDagRunQueue` is empty; the pending partitions are only visible via the
internal `/ui/partitioned_dag_runs` endpoint and can't be cleared via the
public API or `airflowctl`. +1 for the proposed `partition_key` support
(ideally also a "delete all pending partitions for this Dag" option).
--
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]
