adding loguru.catch to functions to facilitate nested stderr messaging

Author: fsecada01

dev_requirements.txt

@@ -21,7 +21,7 @@ distlib==0.3.7
     # via virtualenv
 filelock==3.13.1
     # via virtualenv
-identify==2.5.32
+identify==2.5.33
     # via pre-commit
 isort==5.12.0
     # via -r dev_requirements.in

sqlmodel_crud_utils/a_sync.py

@@ -16,6 +16,7 @@
 upsert = get_sql_dialect_import(dialect=get_val("SQL_DIALECT"))
 
 
+@logger.catch
 async def get_result_from_query(query: SelectOfScalar, session: AsyncSession):
     """
     Processes an SQLModel query object and returns a singular result from the
@@ -37,6 +38,7 @@ async def get_result_from_query(query: SelectOfScalar, session: AsyncSession):
     return results
 
 
+@logger.catch
 async def get_one_or_create(
     session_inst: AsyncSession,
     model: type[SQLModel],
@@ -86,6 +88,7 @@ async def _get_entry(sqlmodel, **key_args):
         return created, False
 
 
+@logger.catch
 async def write_row(data_row: Type[SQLModel], session_inst: AsyncSession):
     """
     Writes a new instance of an SQLModel ORM model to the database, with an
@@ -110,6 +113,7 @@ async def write_row(data_row: Type[SQLModel], session_inst: AsyncSession):
         return False, None
 
 
+@logger.catch
 async def insert_data_rows(data_rows, session_inst: AsyncSession):
     try:
         session_inst.add_all(data_rows)
@@ -145,6 +149,7 @@ async def insert_data_rows(data_rows, session_inst: AsyncSession):
         return status, {"success": processed_rows, "failed": failed_rows}
 
 
+@logger.catch
 async def get_row(
     id_str: str or int,
     session_inst: AsyncSession,
@@ -172,6 +177,7 @@ async def get_row(
     return success, row
 
 
+@logger.catch
 async def get_rows(
     session_inst: AsyncSession,
     model: type[SQLModel],
@@ -244,6 +250,7 @@ async def get_rows(
     return success, results
 
 
+@logger.catch
 async def get_rows_within_id_list(
     id_str_list: list[str | int],
     session_inst: AsyncSession,
@@ -261,6 +268,7 @@ async def get_rows_within_id_list(
     return success, results
 
 
+@logger.catch
 async def delete_row(
     id_str: str or int,
     session_inst: AsyncSession,
@@ -290,6 +298,7 @@ async def delete_row(
     return success
 
 
+@logger.catch
 async def bulk_upsert_mappings(
     payload: list,
     session_inst: AsyncSession,
@@ -316,6 +325,7 @@ async def bulk_upsert_mappings(
         return False
 
 
+@logger.catch
 async def update_row(
     id_str: int | str,
     data: dict,

sqlmodel_crud_utils/sync.py

@@ -15,6 +15,7 @@
 upsert = get_sql_dialect_import(dialect=get_val("SQL_DIALECT"))
 
 
+@logger.catch
 def get_result_from_query(query: SelectOfScalar, session: Session):
     """
     Processes an SQLModel query object and returns a singular result from the
@@ -36,6 +37,7 @@ def get_result_from_query(query: SelectOfScalar, session: Session):
     return results
 
 
+@logger.catch
 def get_one_or_create(
     session_inst: Session,
     model: type[SQLModel],
@@ -85,6 +87,7 @@ def _get_entry(sqlmodel, **key_args):
         return created, False
 
 
+@logger.catch
 def write_row(data_row: Type[SQLModel], session_inst: Session):
     """
     Writes a new instance of an SQLModel ORM model to the database, with an
@@ -109,6 +112,7 @@ def write_row(data_row: Type[SQLModel], session_inst: Session):
         return False, None
 
 
+@logger.catch
 def insert_data_rows(data_rows, session_inst: Session):
     try:
         session_inst.add_all(data_rows)
@@ -142,6 +146,7 @@ def insert_data_rows(data_rows, session_inst: Session):
         return status, {"success": processed_rows, "failed": failed_rows}
 
 
+@logger.catch
 def get_row(
     id_str: str or int,
     session_inst: Session,
@@ -169,6 +174,7 @@ def get_row(
     return success, row
 
 
+@logger.catch
 def get_rows(
     session_inst: Session,
     model: type[SQLModel],
@@ -241,6 +247,7 @@ def get_rows(
     return success, results
 
 
+@logger.catch
 def get_rows_within_id_list(
     id_str_list: list[str | int],
     session_inst: Session,
@@ -258,6 +265,7 @@ def get_rows_within_id_list(
     return success, results
 
 
+@logger.catch
 def delete_row(
     id_str: str or int,
     session_inst: Session,
@@ -287,6 +295,7 @@ def delete_row(
     return success
 
 
+@logger.catch
 def bulk_upsert_mappings(
     payload: list,
     session_inst: Session,
@@ -313,6 +322,7 @@ def bulk_upsert_mappings(
         return False
 
 
+@logger.catch
 def update_row(
     id_str: int | str,
     data: dict,