Skip to content

Commit

Permalink
Merge pull request #52 from dfinity/taskid
Browse files Browse the repository at this point in the history
Python typing strikes again.  We might have been missing task_id.
  • Loading branch information
DFINITYManu authored Oct 2, 2024
2 parents ac7a50d + 0583588 commit 9e1607f
Showing 1 changed file with 8 additions and 0 deletions.
8 changes: 8 additions & 0 deletions plugins/sensors/ic_os_rollout.py
Original file line number Diff line number Diff line change
Expand Up @@ -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(
Expand Down

0 comments on commit 9e1607f

Please sign in to comment.