From c7bfafc6eeb7782d68d836278cf9a2605b6e07ab Mon Sep 17 00:00:00 2001 From: Yannick PEROUX Date: Mon, 25 Nov 2019 11:47:05 +0100 Subject: [PATCH 1/2] Don't overwrite psycopg2 adapters when creating the connection --- procrastinate/aiopg_connector.py | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/procrastinate/aiopg_connector.py b/procrastinate/aiopg_connector.py index d2124e8d3..fb6907b44 100644 --- a/procrastinate/aiopg_connector.py +++ b/procrastinate/aiopg_connector.py @@ -16,6 +16,11 @@ def wrap_json(arguments: Dict[str, Any]): def get_connection(dsn="", **kwargs) -> Awaitable[aiopg.Connection]: + # tell aiopg not to register adapters for hstore & json by default, as + # those are registered at the module level and could overwritte previously + # defined adapters + kwargs.setdefault("enable_json", False) + kwargs.setdefault("enable_hstore", False) return aiopg.connect(dsn=dsn, **kwargs) From a779a9532b7ddc8810f7e58cd1b46a6600c06283 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Yannick=20P=C3=89ROUX?= Date: Mon, 25 Nov 2019 13:56:12 +0100 Subject: [PATCH 2/2] Update procrastinate/aiopg_connector.py Co-Authored-By: Joachim Jablon --- procrastinate/aiopg_connector.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/procrastinate/aiopg_connector.py b/procrastinate/aiopg_connector.py index fb6907b44..c9000607a 100644 --- a/procrastinate/aiopg_connector.py +++ b/procrastinate/aiopg_connector.py @@ -17,7 +17,7 @@ def wrap_json(arguments: Dict[str, Any]): def get_connection(dsn="", **kwargs) -> Awaitable[aiopg.Connection]: # tell aiopg not to register adapters for hstore & json by default, as - # those are registered at the module level and could overwritte previously + # those are registered at the module level and could overwrite previously # defined adapters kwargs.setdefault("enable_json", False) kwargs.setdefault("enable_hstore", False)