diff --git a/awx/main/management/commands/run_callback_receiver.py b/awx/main/management/commands/run_callback_receiver.py index 2e5ef0f5e9..0378d27d02 100644 --- a/awx/main/management/commands/run_callback_receiver.py +++ b/awx/main/management/commands/run_callback_receiver.py @@ -187,6 +187,8 @@ class CallbackReceiver(object): if messages_processed >= MAX_REQUESTS: print("Shutting down message receiver") pool_subscriber.close() + pool_context.term() + time.sleep(0.1) sys.exit(0) class Command(NoArgsCommand):