Fix failing tests

alephdata · Oct 8, 2024 · 067beb8 · 067beb8
1 parent bde2b38
commit 067beb8
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 8 deletions.
diff --git a/servicelayer/taskqueue.py b/servicelayer/taskqueue.py
@@ -124,8 +124,6 @@ def get_status(self):
         status["last_update"] = last_update
 
         for stage in self.conn.smembers(self.active_stages_key):
-            stage_key = self.get_stage_key(stage)
-
             num_pending = unpack_int(
                 self.conn.scard(make_key(PREFIX, "qds", self.name, stage, "pending"))
             )

diff --git a/tests/test_dataset.py b/tests/test_dataset.py
@@ -18,12 +18,6 @@ def setUp(self):
             conn=self.connection, name=dataset_from_collection_id(self.collection_id)
         )
 
-    def test_get_stage_key(self):
-        stage = "ingest"
-        assert (
-            self.dataset.get_stage_key(stage) == f"tq:qds:{self.collection_id}:{stage}"
-        )
-
     def test_get_active_datasets_key(self):
         assert self.dataset.key == "tq:qdatasets"