Merge branch 'develop' into dist/risotto/risotto-2.8.0/develop

src/risotto/dispatcher.py

@@ -260,6 +260,15 @@ class PublishDispatcher:
                                                             False,
                                                             False,
                                                             )
+        async with self.pool.acquire() as log_connection:
+            await log_connection.set_type_codec(
+                'json',
+                encoder=dumps,
+                decoder=loads,
+                schema='pg_catalog'
+            )
+            async with log_connection.transaction():
+                risotto_context.log_connection = log_connection
                 async with self.pool.acquire() as connection:
                     await connection.set_type_codec(
                         'json',