diff --git a/tasks.py b/tasks.py index a5f387714411d4cb04904a63532188d55dc200bd..275052795e583108701fe28cc96ae647be7016f3 100644 --- a/tasks.py +++ b/tasks.py @@ -90,12 +90,13 @@ def celery_certify_account(json, session): email= json['email'] fullname= json['fullname'] queuename= rc_util.encode_name(username) - updated_by= f'{username}@login005' + updated_by= f'{username}' + host= 'login005' print("CERTIFY : "+time.strftime("%m-%d-%Y_%H:%M:%S") + '\tUser ' + username + ' added to queue') send_msg('certifying account', room) print(username) - rc_util.certify_account(username, queuename, 'ok', 'all', updated_by) + rc_util.certify_account(username, queuename, 'ok', 'all', updated_by, host) print('sent account info') print('Waiting for certification...') rc_util.consume(queuename, routing_key=f'certified.{queuename}', callback=certify_gen_f(room))