We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a2f02f1 commit 0027b9aCopy full SHA for 0027b9a
services/sidecar/src/simcore_service_sidecar/rabbitmq.py
@@ -67,7 +67,7 @@ async def connect(self):
67
self.connection.add_reconnect_callback(_reconnect_callback)
68
69
log.debug("Creating channel")
70
- self.channel = self.connection.channel(publisher_confirms=False)
+ self.channel = await self.connection.channel(publisher_confirms=False)
71
self.channel.add_close_callback(_channel_close_callback)
72
73
log.debug("Declaring %s exchange", self.config.channels["log"])
0 commit comments