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"
         )