(fix) field validation errors

d3nbr0 · Dec 5, 2024 · a6f6834 · a6f6834
1 parent 1403aeb
commit a6f6834
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/aiocarrot/consumer/consumer.py b/aiocarrot/consumer/consumer.py
@@ -103,7 +103,7 @@ async def on_message(self, _cid: str, _cnm: str, **kwargs) -> None:
 
             value, errors = field.validate(kwargs[field.name])
 
-            if not value:
+            if errors is not None:
                 logger.error(
                     f'[{_cid}] Error processing the message <{_cnm}>: field "{field.name}" with value "{kwargs[field.name]}" '
                     f'does not meet the validation conditions - {str(errors)}',
@@ -115,8 +115,8 @@ async def on_message(self, _cid: str, _cnm: str, **kwargs) -> None:
 
         try:
             await message.handler(**values)
-        except BaseException:
-            logger.trace(f'[{_cid}] Message processing failed <{_cnm}>')
+        except BaseException as e:
+            logger.error(f'[{_cid}] Message processing failed <{_cnm}>: {str(e)}')
             return
 
         logger.info(f'[{_cid}] Message <{_cnm}> processed successfully')