Sink gets stuck on RPC CancelledError

[kinnarr]

Jan 28 08:58:46 igel metricq-sink-websocket[82910]: 2021-01-28 08:58:46,708 [ERROR   ] [metricq_sink_websocket.views] error during message handling <class 'concurrent.futures._base.CancelledError'>:
Jan 28 08:58:46 igel metricq-sink-websocket[82910]: Traceback (most recent call last):
Jan 28 08:58:46 igel metricq-sink-websocket[82910]:   File "/home/service/metricq-sink-websocket/metricq_sink_websocket/views.py", line 28, in websocket_handler
Jan 28 08:58:46 igel metricq-sink-websocket[82910]:     metadata = await sink.subscribe_ws(ws, new_metrics - metrics)
Jan 28 08:58:46 igel metricq-sink-websocket[82910]:   File "/home/service/metricq-sink-websocket/metricq_sink_websocket/sink.py", line 130, in subscribe_ws
Jan 28 08:58:46 igel metricq-sink-websocket[82910]:     response = await self.subscribe(list(subscribe_metrics), metadata=True)
Jan 28 08:58:46 igel metricq-sink-websocket[82910]:   File "/home/service/metricq-sink-websocket/metricq_sink_websocket/sink.py", line 103, in subscribe
Jan 28 08:58:46 igel metricq-sink-websocket[82910]:     return await super().subscribe(self._primary_to_internal(metrics), **kwargs)
Jan 28 08:58:46 igel metricq-sink-websocket[82910]:   File "/home/service/envs/websocket/lib/python3.7/site-packages/metricq/sink.py", line 134, in subscribe
Jan 28 08:58:46 igel metricq-sink-websocket[82910]:     response = await self.rpc("sink.subscribe", metrics=metrics, **kwargs)
Jan 28 08:58:46 igel metricq-sink-websocket[82910]:   File "/home/service/envs/websocket/lib/python3.7/site-packages/metricq/client.py", line 82, in rpc
Jan 28 08:58:46 igel metricq-sink-websocket[82910]:     **kwargs,
Jan 28 08:58:46 igel metricq-sink-websocket[82910]:   File "/home/service/envs/websocket/lib/python3.7/site-packages/metricq/agent.py", line 373, in rpc
Jan 28 08:58:46 igel metricq-sink-websocket[82910]:     return await asyncio.wait_for(request_future, timeout=timeout)
Jan 28 08:58:46 igel metricq-sink-websocket[82910]:   File "/home/service/envs/websocket/lib/python3.7/asyncio/tasks.py", line 409, in wait_for
Jan 28 08:58:46 igel metricq-sink-websocket[82910]:     await waiter
Jan 28 08:58:46 igel metricq-sink-websocket[82910]: concurrent.futures._base.CancelledError