RehanAhmad25 commented on code in PR #74583:
URL: https://github.com/apache/airflow/pull/74583#discussion_r4325626920
##########
task-sdk/src/airflow/sdk/definitions/timetables/assets.py:
##########
@@ -77,6 +77,10 @@ class PartitionedAssetTimetable(AssetTriggeredTimetable):
partition_mapper_config: dict[BaseAsset, PartitionMapper] =
attrs.field(factory=dict)
default_partition_mapper: PartitionMapper = IdentityMapper()
+ # Opt-in refire on late/corrected partition events: "rerun" (clear +
re-run the
+ # existing DagRun, attempts increment) or "newrun" (a new DagRun per
refire).
+ # None = fire once (default, no behavior change).
+ refire_policy: str | None = None
Review Comment:
Could we validate this value against None, "rerun", and "newrun"? As
written, a typo such as "rerun " is accepted and then falls through to the
new-run behavior in the scheduler, which can create a duplicate DagRun instead
of rerunning the existing one.
--
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]
