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)