|
4 | 4 | from collections.abc import AsyncIterator |
5 | 5 | from datetime import timedelta |
6 | 6 |
|
7 | | -import orjson |
8 | 7 | from models_library.healthchecks import IsNonResponsive, IsResponsive, LivenessResult |
9 | 8 | from settings_library.postgres import PostgresSettings |
10 | 9 | from sqlalchemy.exc import SQLAlchemyError |
@@ -45,8 +44,6 @@ async def create_async_engine_and_database_ready( |
45 | 44 | connect_args={"server_settings": server_settings}, |
46 | 45 | pool_pre_ping=True, # https://docs.sqlalchemy.org/en/14/core/pooling.html#dealing-with-disconnects |
47 | 46 | future=True, # this uses sqlalchemy 2.0 API, shall be removed when sqlalchemy 2.0 is released |
48 | | - json_serializer=orjson.dumps, |
49 | | - json_deserializer=orjson.loads, |
50 | 47 | ) |
51 | 48 |
|
52 | 49 | try: |
@@ -98,8 +95,6 @@ async def with_async_pg_engine( |
98 | 95 | connect_args={"server_settings": server_settings}, |
99 | 96 | pool_pre_ping=True, # https://docs.sqlalchemy.org/en/14/core/pooling.html#dealing-with-disconnects |
100 | 97 | future=True, # this uses sqlalchemy 2.0 API, shall be removed when sqlalchemy 2.0 is released |
101 | | - json_serializer=orjson.dumps, |
102 | | - json_deserializer=orjson.loads, |
103 | 98 | ) |
104 | 99 | yield engine |
105 | 100 | finally: |
|
0 commit comments