From 477134ae6e60908ffc51e424b4a8bba18a40b971 Mon Sep 17 00:00:00 2001 From: Alex Stefanescu Date: Mon, 30 Sep 2024 16:38:56 +0200 Subject: [PATCH] Temporary commit --- servicelayer/taskqueue.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/servicelayer/taskqueue.py b/servicelayer/taskqueue.py index bd2ffc2..342b46d 100644 --- 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)