diff --git a/airflow/sensors/date_time.py b/airflow/sensors/date_time.py index f1a61540c1f9a..65880ebb9e754 100644 --- a/airflow/sensors/date_time.py +++ b/airflow/sensors/date_time.py @@ -89,11 +89,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 0701a1c24480c..4a7f2e9d48d74 100644 --- a/airflow/sensors/time_sensor.py +++ b/airflow/sensors/time_sensor.py @@ -71,11 +71,11 @@ def __init__(self, *, target_time, **kwargs): ) 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", )