Update Consumer.py

Consumer.py

@@ -152,10 +152,13 @@ async def main():
             print(f"Received task {uid}")
 
             # Create async task
+            taskold = None
+            if uid in active_tasks:
+               taskold = active_tasks[uid]
             task = asyncio.create_task(process_task(uid, code))
             active_tasks[uid] = task
-            if uid in active_tasks:
-                active_tasks[uid].cancel()
+            if taskold and taskold.is_running():
+                taskold.cancel()
 
         await asyncio.sleep(POLL_INTERVAL)