Fix tests now that we clean up finished tasks

alephdata · Jul 4, 2024 · a92c592 · a92c592
1 parent f12e13e
commit a92c592
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tests/test_taskqueue.py b/tests/test_taskqueue.py
@@ -110,7 +110,7 @@ def test_task_queue(self):
 
         worker.ack_message(worker.test_task, channel)
         status = dataset.get_status()
-        assert status["finished"] == 1, status
+        assert status["finished"] == 0, status
         assert status["pending"] == 0, status
         assert status["running"] == 0, status
         started = unpack_datetime(status["start_time"])