This is an automated email from the ASF dual-hosted git repository. ephraimanierobi pushed a commit to branch v2-7-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit d0886260d7de08f5605ee1e0a6846082620a4753 Author: Wei Lee <[email protected]> AuthorDate: Thu Aug 31 03:32:47 2023 +0800 fix(sensors): move trigger initialization from __init___ to execute (#33926) in https://github.com/apache/airflow/pull/33403, we move trigger initialization to __init__ which causes a failure for one uses template variable (cherry picked from commit eaa6126e45ab9869c11c59363e52490aa6dff91f) --- airflow/sensors/date_time.py | 4 ++-- airflow/sensors/time_sensor.py | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/airflow/sensors/date_time.py b/airflow/sensors/date_time.py index 2ac17ca1b6..5403f7e019 100644 --- a/airflow/sensors/date_time.py +++ b/airflow/sensors/date_time.py @@ -87,11 +87,11 @@ class DateTimeSensorAsync(DateTimeSensor): def __init__(self, **kwargs) -> None: super().__init__(**kwargs) - self.trigger = DateTimeTrigger(moment=timezone.parse(self.target_time)) def execute(self, context: Context): + trigger = DateTimeTrigger(moment=timezone.parse(self.target_time)) self.defer( - trigger=self.trigger, + trigger=trigger, method_name="execute_complete", ) diff --git a/airflow/sensors/time_sensor.py b/airflow/sensors/time_sensor.py index c459003090..0d7d0a088f 100644 --- a/airflow/sensors/time_sensor.py +++ b/airflow/sensors/time_sensor.py @@ -68,11 +68,11 @@ class TimeSensorAsync(BaseSensorOperator): ) self.target_datetime = timezone.convert_to_utc(aware_time) - self.trigger = DateTimeTrigger(moment=self.target_datetime) def execute(self, context: Context): + trigger = DateTimeTrigger(moment=self.target_datetime) self.defer( - trigger=self.trigger, + trigger=trigger, method_name="execute_complete", )
