Merge tag '0.0.3' into develop

0.0.3

Author: s3rius

.flake8

@@ -6,6 +6,8 @@ extend-ignore = E203
 docstring_style=sphinx
 
 ignore =
+  ; Found a line that starts with a dot
+  WPS348,
   ; `noqa` comments overuse ))))
   WPS402,
   ; Found `%` string formatting

taskiq/abc/broker.py

@@ -1,4 +1,6 @@
 import inspect
+import os
+import sys
 from abc import ABC, abstractmethod
 from functools import wraps
 from logging import getLogger
@@ -187,9 +189,18 @@ def inner(
             ) -> AsyncTaskiqDecoratedTask[_FuncParams, _ReturnType]:
                 nonlocal inner_task_name  # noqa: WPS420
                 if inner_task_name is None:
-                    inner_task_name = (  # noqa: WPS442
-                        f"{func.__module__}:{func.__name__}"
-                    )
+                    fmodule = func.__module__
+                    if fmodule == "__main__":
+                        fmodule = ".".join(  # noqa: WPS220
+                            sys.argv[0]
+                            .removesuffix(
+                                ".py",
+                            )
+                            .split(
+                                os.path.sep,
+                            ),
+                        )
+                    inner_task_name = f"{fmodule}:{func.__name__}"  # noqa: WPS442
                 wrapper = wraps(func)
 
                 decorated_task = wrapper(

taskiq/cli/worker.py

@@ -153,7 +153,7 @@ async def shutdown_broker(broker: AsyncBroker, timeout: float) -> None:
         )
 
 
-def start_listen(args: TaskiqArgs) -> None:  # noqa: C901, WPS213
+def start_listen(args: TaskiqArgs) -> None:  # noqa: C901
     """
     This function starts actual listening process.
 
@@ -209,9 +209,7 @@ def interrupt_handler(_signum: int, _frame: Any) -> None:
         loop.run_until_complete(async_listen_messages(broker, args))
     except KeyboardInterrupt:
         logger.warning("Worker process interrupted.")
-    except Exception as exc:
-        logger.error("Exception found: %s", exc, exc_info=True)
-    loop.run_until_complete(shutdown_broker(broker, args.shutdown_timeout))
+        loop.run_until_complete(shutdown_broker(broker, args.shutdown_timeout))
 
 
 def watch_workers_restarts(args: TaskiqArgs) -> None: