Update log level to debug from warning about scheduled_duration metr…

…ic (#38180) --------- Co-authored-by: Tzu-ping Chung <[email protected]> Co-authored-by: Wei Lee <[email protected]>
apache · Mar 27, 2024 · b9e96df · b9e96df
1 parent 4ca80cc
commit b9e96df
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/airflow/models/taskinstance.py b/airflow/models/taskinstance.py
@@ -2391,8 +2391,10 @@ def emit_state_change_metric(self, new_state: TaskInstanceState) -> None:
         elif new_state == TaskInstanceState.QUEUED:
             metric_name = "scheduled_duration"
             if self.start_date is None:
-                # same comment as above
-                self.log.warning(
+                # This check does not work correctly before fields like `scheduled_dttm` are implemented.
+                # TODO: Change the level to WARNING once it's viable.
+                # see #30612 #34493 and #34771 for more details
+                self.log.debug(
                     "cannot record %s for task %s because previous state change time has not been saved",
                     metric_name,
                     self.task_id,