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'])