Fix double increment bug, remove deprecated key from test

alephdata · Sep 25, 2024 · a8f8274 · a8f8274
1 parent d78ce5e
commit a8f8274
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 2 deletions.
diff --git 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
@@ -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"
         )