From a8f8274612ea5ef13760ecd058b627f81ff6e872 Mon Sep 17 00:00:00 2001 From: Alex Stefanescu Date: Wed, 25 Sep 2024 18:23:27 +0200 Subject: [PATCH] Fix double increment bug, remove deprecated key from test --- servicelayer/taskqueue.py | 1 - tests/test_dataset.py | 1 - 2 files changed, 2 deletions(-) diff --git a/servicelayer/taskqueue.py b/servicelayer/taskqueue.py index 953566a..950bafb 100644 --- a/servicelayer/taskqueue.py +++ b/servicelayer/taskqueue.py @@ -328,7 +328,6 @@ def mark_done(self, task: Task): stage_key = self.get_stage_key(stage) pipe.srem(make_key(stage_key, "pending"), task_id) pipe.srem(make_key(stage_key, "running"), task_id) - pipe.incr(make_key(stage_key, "finished")) # update dataset timestamps pipe.set(self.last_update_key, pack_now()) diff --git a/tests/test_dataset.py b/tests/test_dataset.py index f530b60..db0bb66 100644 --- a/tests/test_dataset.py +++ b/tests/test_dataset.py @@ -35,7 +35,6 @@ def test_get_active_stages_key(self): def test_get_timestamp_keys(self): assert self.dataset.start_key == f"tq:qdj:{self.collection_id}:start" - assert self.dataset.end_key == f"tq:qdj:{self.collection_id}:end" assert ( self.dataset.last_update_key == f"tq:qdj:{self.collection_id}:last_update" )