We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 7c44eba + fe6adce commit b16f0cfCopy full SHA for b16f0cf
airflow_ha/operator.py
@@ -58,7 +58,9 @@ def __init__(
58
self._runtime = timedelta(seconds=runtime) if isinstance(runtime, int) else runtime
59
self._endtime = time.fromisoformat(endtime) if isinstance(endtime, str) else endtime
60
self._maxretrigger = maxretrigger or None
61
- self._start_date_or_logical_date = start_date_or_logical_date
+ self._start_date_or_logical_date = (
62
+ start_date_or_logical_date if start_date_or_logical_date.endswith("_date") else f"{start_date_or_logical_date}_date"
63
+ )
64
65
# These are kwarsg to pass to the trigger operators
66
self._pass_trigger_kwargs = pass_trigger_kwargs or {}
0 commit comments