Temporary commit

alephdata · Sep 30, 2024 · 477134a · 477134a
1 parent 4485dc1
commit 477134a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/servicelayer/taskqueue.py b/servicelayer/taskqueue.py
@@ -278,7 +278,7 @@ def remove_task(self, task_id, stage):
     def checkout_task(self, task_id, stage):
         """Update state when a task is checked out for execution"""
         pipe = self.conn.pipeline()
-        log.critical(f'Pending tasks: {pipe.smembers(make_key(PREFIX, "qds", self.name, stage, "pending"))}')
+        log.critical(f'Pending tasks: {list(pipe.smembers(make_key(PREFIX, "qds", self.name, stage, "pending")))}')
         log.info(f"Checking out task: {task_id}")
         # add the dataset to active datasets
         pipe.sadd(self.key, self.name)
@@ -289,7 +289,7 @@ def checkout_task(self, task_id, stage):
         pipe.srem(make_key(PREFIX, "qds", self.name, stage, "pending"), task_id)
         pipe.sadd(make_key(PREFIX, "qds", self.name, stage, "running"), task_id)
 
-        log.critical(f'Pending tasks: {pipe.smembers(make_key(PREFIX, "qds", self.name, stage, "pending"))}')
+        log.critical(f'Pending tasks: {list(pipe.smembers(make_key(PREFIX, "qds", self.name, stage, "pending")))}')
 
         # TODO - remove after all the wrong keys are gone
         stage_key = self.get_stage_key(stage)