chore: change docstrings + set mode json for better object dumps (#304)

Author: KatantDev

taskiq/abc/serializer.py

@@ -19,6 +19,6 @@ def loadb(self, value: bytes) -> Any:
         """
         Parse byte-encoded value received from the wire.
 
-        :param message: value to parse.
+        :param value: value to decode.
         :return: decoded value.
         """

taskiq/api/receiver.py

@@ -45,7 +45,7 @@ async def run_receiver_task(
     :param max_prefetch: maximum number of tasks to prefetch.
     :param propagate_exceptions: whether to propagate exceptions in generators or not.
     :param run_startup: whether to run startup function or not.
-
+    :param ack_time: acknowledge type to use.
     :raises asyncio.CancelledError: if the task was cancelled.
     """
 

taskiq/compat.py

@@ -28,7 +28,7 @@ def model_validate(
         return model_class.model_validate(message)
 
     def model_dump(instance: Model) -> Dict[str, Any]:
-        return instance.model_dump()
+        return instance.model_dump(mode="json")
 
     def model_validate_json(
         model_class: Type[Model],

taskiq/scheduler/merge_functions.py

@@ -49,7 +49,7 @@ def only_new(
     """
     This function preserves only new schedules.
 
-    :param old_tasks: previously discovered tasks.
+    :param _old_tasks: previously discovered tasks.
     :param new_tasks: newly discovered schedules.
     :return: list of new schedules.
     """

taskiq/scheduler/scheduler.py

@@ -38,6 +38,7 @@ async def on_ready(self, source: "ScheduleSource", task: ScheduledTask) -> None:
         This method is called when task is ready to be enqueued.
 
         It's triggered on proper time depending on `task.cron` or `task.time` attribute.
+        :param source: source that triggered this event.
         :param task: task to send
         """
         try: