diff --git a/servicelayer/taskqueue.py b/servicelayer/taskqueue.py index cedec1b..953566a 100644 --- a/servicelayer/taskqueue.py +++ b/servicelayer/taskqueue.py @@ -385,8 +385,6 @@ def is_task_tracked(self, task: Task): task_id = task.task_id stage = task.operation - stage_key = self.get_stage_key(stage) - # A task is considered tracked if # the dataset is in the list of active datasets if dataset not in self.conn.smembers(self.key):