diff --git a/task_manager.py b/task_manager.py index 78c71f7123be87db0360b09262495b35171e1e73..d91902ae074c5cb4908f6e5b30284f691bc3d9ba 100644 --- a/task_manager.py +++ b/task_manager.py @@ -43,6 +43,7 @@ def task_manager(ch, method, properties, body): username = method.routing_key.split('.')[1] task_name = msg['task'] done = success = msg['success'] + routing_key = "" if username not in tracking: current = tracking[username] = record.copy()