diff --git a/scouter/activities/redis.py b/scouter/activities/redis.py index 5689472..b4ad730 100644 --- a/scouter/activities/redis.py +++ b/scouter/activities/redis.py @@ -24,7 +24,7 @@ class Redis(RedisBase): Gets the last data timestamp from 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_hold = self.get(key)