dbschi opened a new issue, #70444:
URL: https://github.com/apache/airflow/issues/70444
### Description
On Airflow 3.3, the following endpoints:
DELETE /api/v2/assets/{asset_id}/queuedEvents
DELETE /api/v2/dags/{dag_id}/assets/queuedEvents
DELETE /api/v2/dags/{dag_id}/assets/{asset_id}/queuedEvents
only support deletion from AssetDagRunQueue but not PartitionedAssetKeyLog
or AssetPartitionDagRun.
I think these should support an optional "partition_key" parameter to mirror
behaviour from POST /api/v2/assets/{asset_id}/materialize.
### Use case/motivation
Sometimes a partitioned event is incorrectly emitted or no longer relevant
for triggering downstream processes, for example:
Data is later determined to be invalid.
The downstream has been triggered by a more recent partition.
Dependency /partition logic has been updated after the partitioned event has
been registered.
In such cases, it will be useful to delete the irrelevant partitioned event
so that it doesn't trigger unintentional downstreams and show up as a stale
asset in the UI.
### Related issues
_No response_
### Are you willing to submit a PR?
- [ ] Yes I am willing to submit a PR!
### Code of Conduct
- [x] I agree to follow this project's [Code of
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
--
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]
