From 5c1c19562f45aa4ecaa6bebc72921d0c2da8b07b Mon Sep 17 00:00:00 2001
From: atlurie <atlurie@uab.edu>
Date: Wed, 13 Apr 2022 17:07:05 -0500
Subject: [PATCH] Wait until all the task return with success msg
---
account_manager.py | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
diff --git a/account_manager.py b/account_manager.py
index 2eccda2..8992745 100755
--- a/account_manager.py
+++ b/account_manager.py
@@ -77,7 +77,15 @@ def callback(channel, method, properties, body):
msg = json.loads(body)
username = msg["username"]
- if msg["success"]:
+ # Check if each task returned success
+ for each_task in msg["success"].values():
+ if each_task == True:
+ success=True
+ else:
+ success=False
+ break
+
+ if success:
print(f"Account for {username} has been {action}ed.\n Updating the user state in DB")
rc_util.update_state(username, state)
else:
--
GitLab