Skip to content

Pre-populate a suggested Partition Key when manually triggering temporal partitioned DAGs #71284

Description

@azhou95

Description

When manually triggering a DAG using a temporal partitioned timetable, the trigger form leaves partition_key blank.

Submitted the form without a key created an unpartitioned DagRun. Although the run may execute successfully, its asset events cannot satisfy partition-aware downstream DAGs. This is an easy operational footgun, particularly for daily asset-driven pipelines.

Use case/motivation

Operators frequently need to manually trigger or rerun daily partitioned DAGs. Currently, they must enter the partition key manually on every trigger.

It would be useful if the form could derive a suggested key, perhaps using some custom function.

Related issues

No response

Are you willing to submit a PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Metadata

Assignees

Labels

area:data-aware-schedulingassets, datasets, AIP-48, AIP-76, AIP-74, Asset Partitionskind:featureFeature Requestsneeds-triagelabel for new issues that we didn't triage yet

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions