From 058358807af1c75022c328712be8b081b879b063 Mon Sep 17 00:00:00 2001 From: Manuel Amador Date: Wed, 2 Oct 2024 15:34:21 +0200 Subject: [PATCH] Python typing strikes again. We might have been missing task_id. --- plugins/sensors/ic_os_rollout.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/plugins/sensors/ic_os_rollout.py b/plugins/sensors/ic_os_rollout.py index 15b4c3b..f83d1bd 100644 --- a/plugins/sensors/ic_os_rollout.py +++ b/plugins/sensors/ic_os_rollout.py @@ -346,8 +346,16 @@ def send_notification_if_necessary(subnet_id: str) -> None: # has not exited the alerts condition in over an hour. now = time.time() key = "alert_check_timestamp" + task_id = context["task_instance"].task_id + self.log.info( + "Pulling alert check timestamp from xcom for %s %s %s", + key, + task_id, + context["task_instance"].map_index, + ) alert_check_timestamp = context["task_instance"].xcom_pull( key=key, + task_ids=task_id, map_indexes=context["task_instance"].map_index, ) self.log.info(