From d6352b8f0de00ea0a0330aec2ab57fe62a8f717e Mon Sep 17 00:00:00 2001 From: Tzu-ping Chung Date: Thu, 7 Apr 2022 02:05:42 +0800 Subject: [PATCH] Clarify in log the unit is seconds --- airflow/sensors/smart_sensor.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/sensors/smart_sensor.py b/airflow/sensors/smart_sensor.py index fbf04bf8a65a7..bc22ab9c541eb 100644 --- a/airflow/sensors/smart_sensor.py +++ b/airflow/sensors/smart_sensor.py @@ -741,7 +741,7 @@ def execute(self, context: Context): duration = timezone.utcnow() - poke_start_time duration_seconds = duration.total_seconds() - self.log.info("Taking %s to execute %s tasks.", duration_seconds, len(self.sensor_works)) + self.log.info("Taking %s seconds to execute %s tasks.", duration_seconds, len(self.sensor_works)) Stats.timing("smart_sensor_operator.loop_duration", duration) Stats.gauge("smart_sensor_operator.executed_tasks", len(self.sensor_works))