Skip to content
Snippets Groups Projects
Commit 55b4bfb9 authored by Bo-Chun Chen's avatar Bo-Chun Chen
Browse files

Update exchange name

After standup meeting, change the exchange name to Register
parent 9b19d748
2 merge requests!23Feat resolve uid gid,!9Feat connection module
from rc_rmq import RCRMQ from rc_rmq import RCRMQ
import json import json
rc_rmq = RCRMQ({'exchange': 'Request'}) rc_rmq = RCRMQ({'exchange': 'Register'})
confirm_rmq = RCRMQ({'exchange': 'Confirm'}) confirm_rmq = RCRMQ({'exchange': 'Confirm'})
tasks = {'ohpc_account': False, 'ohpc_homedir': False, 'ood_account': False, 'slurm_account': False} tasks = {'ohpc_account': False, 'ohpc_homedir': False, 'ood_account': False, 'slurm_account': False}
...@@ -25,6 +25,7 @@ def worker(ch, method, properties, body): ...@@ -25,6 +25,7 @@ def worker(ch, method, properties, body):
done = True done = True
for key, status in tasks.items(): for key, status in tasks.items():
if not status: if not status:
print("{} is not done yet.".format(key))
done = False done = False
if done: if done:
confirm_rmq.stop_consume() confirm_rmq.stop_consume()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment