ClusterRpcProxy support?

[sivabudh]

Hello,

I noticed that when I do:

        with ClusterRpcProxy(CONFIG) as rpc:
            some_results = rpc.some_service_name.some_method()

and when an exception occurs on this peice of code (such as some_service_name cannot be found with a stack trace provided below), that Sentry doesn't get the exception.

Does nameko-sentry support ClusterRpcProxy exception handling? Thanks!

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`