From 0e915f5491dd13776e595c765797cc6921644308 Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Tue, 1 Jul 2025 15:45:03 -0300 Subject: [PATCH] SIENTIAPDE-1110 Update Redis activity to include specific prefixes for keys in last data timestamp and held data, enhancing clarity in data management. --- scouter/activities/redis.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/scouter/activities/redis.py b/scouter/activities/redis.py index 5aea18e..803ada8 100644 --- a/scouter/activities/redis.py +++ b/scouter/activities/redis.py @@ -44,7 +44,7 @@ class Redis(RedisBase): Puts the last data timestamp into redis. """ metadata = input_data['metadata'] - key = f"{input_data['workflow_name']}_{input_data['schedule_name']}" + key = f"last_data_timestamp_{input_data['workflow_name']}_{input_data['schedule_name']}" data = DataFrame(input_data['data']) @@ -81,7 +81,7 @@ class Redis(RedisBase): data = DataFrame(input_data['data']) retention_time = input_data['retention_time'] - key = f"{input_data['workflow_name']}_{input_data['schedule_name']}" + key = f"held_data_{input_data['workflow_name']}_{input_data['schedule_name']}" data_hold = self.get(key)