Merge pull request #9 from OpenMatchmaking/feature-worker-with-rpc-and-custom-loop

Relrin · web-flow · commit 121ae44726d4 · 2018-05-26T12:04:02.000+03:00
Added a custom event loop for RPC client in run() method call
diff --git a/sage_utils/__init__.py b/sage_utils/__init__.py
@@ -1,4 +1,4 @@
 __title__ = 'sage-utils'
-__version__ = '0.5.3'
+__version__ = '0.5.4'
 __license__ = 'BSD'
 VERSION = __version__
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`