From 0b337d00f9108d73980b34bd074cbba7d8cd6b6c Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Fri, 22 Aug 2025 11:24:26 -0300 Subject: [PATCH] SIENTIAPDE-1193 Refactor Redis activity to utilize the new 'now' function for timestamp generation, ensuring consistency with updated datetime handling. This change replaces the direct use of 'datetime.now()' with 'now()' from the temporal constants. --- scouter/activities/redis.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/scouter/activities/redis.py b/scouter/activities/redis.py index 284acd5..56a4313 100644 --- a/scouter/activities/redis.py +++ b/scouter/activities/redis.py @@ -9,9 +9,8 @@ with workflow.unsafe.imports_passed_through(): from sientia_do.observability.logger import Logger from typing import Any from pandas import DataFrame - from datetime import datetime from scouter import metrics - from sientia_do.temporal.constants import DATETIME_FORMAT + from sientia_do.temporal.constants import DATETIME_FORMAT, now class Redis(RedisBase): @@ -225,7 +224,7 @@ class Redis(RedisBase): data: The data used to collect the data. """ metadata = input_data['metadata'] - key = f"data_package_{input_data['workflow_name']}_{input_data['schedule_name']}_{datetime.now().strftime(DATETIME_FORMAT)}" + key = f"data_package_{input_data['workflow_name']}_{input_data['schedule_name']}_{now().strftime(DATETIME_FORMAT)}" data = DataFrame(input_data['data']) held_data = DataFrame(input_data['held_data'])