Skip to content
Snippets Groups Projects
Commit 9656a061 authored by root's avatar root
Browse files

unpacked new field aup from json object and sent to celery

parent ae0e8c52
No related tags found
1 merge request!14feat aup field for account creation
Hide whitespace changes
Inline Side-by-side
Showing
with 2 additions and 1 deletion
tasks.py
+ 2
− 1
View file @ 9656a061
...@@ -51,12 +51,13 @@ def celery_create_account(json, session): ...@@ -51,12 +51,13 @@ def celery_create_account(json, session):
email= json['email'] email= json['email']
fullname= json['fullname'] fullname= json['fullname']
reason= json['reason'] reason= json['reason']
aup= json['aup']
queuename= rc_util.encode_name(username) queuename= rc_util.encode_name(username)
print(time.strftime("%m-%d-%Y_%H:%M:%S") + '\tUser ' + username + ' added to queue') print(time.strftime("%m-%d-%Y_%H:%M:%S") + '\tUser ' + username + ' added to queue')
send_msg('creating account', room) send_msg('creating account', room)
print(username) print(username)
rc_util.add_account(username, queuename, email, fullname, reason) rc_util.add_account(username, queuename, email, fullname, reason, aup)
print('sent account info') print('sent account info')
print('Waiting for completion...') print('Waiting for completion...')
rc_util.consume(queuename, routing_key=f'complete.{queuename}', callback=gen_f(room)) rc_util.consume(queuename, routing_key=f'complete.{queuename}', callback=gen_f(room))
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment