@staticmethod
 def _encode_jsonb(value: Union[Dict, List]) -> str:
 return json.dumps(value, default=str, ensure_ascii=False)
 @staticmethod
 def _decode_jsonb(value: str) -> Union[Dict, List]:
 return json.loads(value)
 async def _init_connection(self, conn: asyncpg.Connection) -> None:
 await conn.set_type_codec(
 'jsonb',
 encoder=self._encode_jsonb,
 decoder=self._decode_jsonb,
 schema='pg_catalog',
 )