diff --git a/tasks.py b/tasks.py index 72539c9f9bd4b6e451651c6d85736a0e8917a732..b2eddf3bf10f22e55af427fecc9ccbc0184675ac 100644 --- a/tasks.py +++ b/tasks.py @@ -90,11 +90,13 @@ def celery_certify_account(json, session): email= json['email'] fullname= json['fullname'] queuename= rc_util.encode_name(username) + updated_by= f'{username}' + host= vars.app_host 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') + 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))