Added a custom event loop for RPC client in run() method call

Relrin · Relrin · commit 12c5e8aba28b · 2018-05-26T12:02:44.000+03:00
diff --git a/sage_utils/amqp/workers.py b/sage_utils/amqp/workers.py
@@ -33,7 +33,8 @@ async def run(self, *args, loop=None, **kwargs):
             routing_key=self.REQUEST_QUEUE_NAME,
             request_exchange=self.REQUEST_EXCHANGE_NAME,
             response_queue='',
-            response_exchange=self.RESPONSE_EXCHANGE_NAME
+            response_exchange=self.RESPONSE_EXCHANGE_NAME,
+            loop=loop
         )
 
         is_registered = False

Original file line number	Diff line number	Diff line change
`@@ -33,7 +33,8 @@ async def run(self, args, loop=None, *kwargs):`
`33`	`33`	`routing_key=self.REQUEST_QUEUE_NAME,`
`34`	`34`	`request_exchange=self.REQUEST_EXCHANGE_NAME,`
`35`	`35`	`response_queue='',`
`36`		`- response_exchange=self.RESPONSE_EXCHANGE_NAME`
	`36`	`+ response_exchange=self.RESPONSE_EXCHANGE_NAME,`
	`37`	`+ loop=loop`
`37`	`38`	`)`
`38`	`39`
`39`	`40`	`is_registered = False`