Commit 116cb27a authored by Krish Moodbidri's avatar Krish Moodbidri
Browse files

Update tasks.py

parent b3724042
Pipeline #6111 canceled with stage
...@@ -94,11 +94,7 @@ def celery_certify_account(json, session): ...@@ -94,11 +94,7 @@ def celery_certify_account(json, session):
print("CERTIFY : "+time.strftime("%m-%d-%Y_%H:%M:%S") + '\tUser ' + username + ' added to queue') print("CERTIFY : "+time.strftime("%m-%d-%Y_%H:%M:%S") + '\tUser ' + username + ' added to queue')
send_msg('certifying account', room) send_msg('certifying account', room)
print(username) print(username)
<<<<<<< HEAD
rc_util.certify_account(username, queuename, updated_by, 'ok', 'all') rc_util.certify_account(username, queuename, updated_by, 'ok', 'all')
=======
rc_util.certify_account(username, queuename, 'ok', 'all')
>>>>>>> parent of bcc5650... Added updated_by field
print('sent account info') print('sent account info')
print('Waiting for certification...') print('Waiting for certification...')
rc_util.consume(queuename, routing_key=f'certified.{queuename}', callback=certify_gen_f(room)) rc_util.consume(queuename, routing_key=f'certified.{queuename}', callback=certify_gen_f(room))
Supports Markdown
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