with ClusterRpcProxy(CONFIG) as rpc:
some_results = rpc.some_service_name.some_method()
celery | File "/usr/local/lib/python3.7/site-packages/nameko/amqp/publish.py", line 210, in publish
celery | **publish_kwargs
celery | File "/usr/local/lib/python3.7/site-packages/kombu/messaging.py", line 181, in publish
celery | exchange_name, declare,
celery | File "/usr/local/lib/python3.7/site-packages/kombu/connection.py", line 518, in _ensured
celery | return fun(*args, **kwargs)
celery | File "/usr/local/lib/python3.7/site-packages/kombu/messaging.py", line 203, in _publish
celery | mandatory=mandatory, immediate=immediate,
celery | File "/usr/local/lib/python3.7/site-packages/amqp/channel.py", line 1784, in basic_publish_confirm
celery | self.wait([spec.Basic.Ack, spec.Basic.Nack], callback=confirm_handler)
celery | File "/usr/local/lib/python3.7/site-packages/amqp/abstract_channel.py", line 88, in wait
celery | self.connection.drain_events(timeout=timeout)
celery | File "/usr/local/lib/python3.7/site-packages/amqp/connection.py", line 505, in drain_events
celery | while not self.blocking_read(timeout):
celery | File "/usr/local/lib/python3.7/site-packages/amqp/connection.py", line 511, in blocking_read
celery | return self.on_inbound_frame(frame)
celery | File "/usr/local/lib/python3.7/site-packages/amqp/method_framing.py", line 79, in on_frame
celery | callback(channel, msg.frame_method, msg.frame_args, msg)
celery | File "/usr/local/lib/python3.7/site-packages/amqp/connection.py", line 518, in on_inbound_method
celery | method_sig, payload, content,
celery | File "/usr/local/lib/python3.7/site-packages/amqp/abstract_channel.py", line 145, in dispatch_method
celery | listener(*args)
celery | File "/usr/local/lib/python3.7/site-packages/amqp/channel.py", line 2001, in _on_basic_return
celery | raise exc
celery | amqp.exceptions.ChannelError: Basic.return: (312) NO_ROUTE
celery |
celery | During handling of the above exception, another exception occurred:
celery |
celery | Traceback (most recent call last):
celery | File "/usr/local/lib/python3.7/site-packages/nameko/rpc.py", line 445, in _call
celery | extra_headers=extra_headers
celery | File "/usr/local/lib/python3.7/site-packages/nameko/amqp/publish.py", line 214, in publish
celery | raise UndeliverableMessage()
celery | nameko.amqp.publish.UndeliverableMessage
celery |
celery | During handling of the above exception, another exception occurred:
celery |
celery | Traceback (most recent call last):
celery | File "/source/reader/services.py", line 132, in _some_function
celery | some_piece_of_code
celery | File "/usr/local/lib/python3.7/site-packages/my_code/some_folder/my_file.py", line 585, in some_function_i_call
celery | some_results = rpc.some_service_name.some_method()
celery | File "/usr/local/lib/python3.7/site-packages/nameko/rpc.py", line 372, in __call__
celery | reply = self._call(*args, **kwargs)
celery | File "/usr/local/lib/python3.7/site-packages/nameko/rpc.py", line 448, in _call
celery | raise UnknownService(self.service_name)
celery | nameko.exceptions.UnknownService: Unknown service `some_service`