From 14d8c5b8f59b834043acf738c109ea29fd5b9ce4 Mon Sep 17 00:00:00 2001 From: Krish Moodbidri <krish94@uab.edu> Date: Wed, 2 Sep 2020 14:05:35 +0000 Subject: [PATCH] decode json object, create account usinf rc_util call, wait for account creation to complete using rc_util.consume --- tasks.py | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/tasks.py b/tasks.py index 1e8a415..d73e3a0 100644 --- a/tasks.py +++ b/tasks.py @@ -3,6 +3,7 @@ import time from flask_socketio import SocketIO import subprocess import vars +import rc_util from gevent import monkey monkey.patch_all(subprocess=True) @@ -19,12 +20,17 @@ def send_msg(event, room): @celery.task -def celery_create_account(username, fullname, reason, session): +def celery_create_account(json, session): room = session + username= json['username'] + email= json['email'] + fullname= json['fullname'] + reason= json['reason'] print(time.strftime("%m-%d-%Y_%H:%M:%S") + '\tUser ' + username + ' added to queue') send_msg('creating account', room) print(username) - subprocess.call(["/opt/rabbitmq_agents/create_account.py", username, email, fullname, reason]) - print(username + email + fullname + reason) + #subprocess.call(["/opt/rabbitmq_agents/create_account.py", username, email, fullname, reason]) + rc_util.add_account(username, email, fullname, reason) + rc_util.consume(username) print(time.strftime("%m-%d-%Y_%H:%M:%S") + '\tAccount successfully created for ' + username) send_msg('account ready', room) -- GitLab