File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -153,7 +153,7 @@ async def shutdown_broker(broker: AsyncBroker, timeout: float) -> None:
153
153
)
154
154
155
155
156
- def start_listen (args : TaskiqArgs ) -> None : # noqa: C901, WPS213
156
+ def start_listen (args : TaskiqArgs ) -> None : # noqa: C901
157
157
"""
158
158
This function starts actual listening process.
159
159
@@ -209,9 +209,7 @@ def interrupt_handler(_signum: int, _frame: Any) -> None:
209
209
loop .run_until_complete (async_listen_messages (broker , args ))
210
210
except KeyboardInterrupt :
211
211
logger .warning ("Worker process interrupted." )
212
- except Exception as exc :
213
- logger .error ("Exception found: %s" , exc , exc_info = True )
214
- loop .run_until_complete (shutdown_broker (broker , args .shutdown_timeout ))
212
+ loop .run_until_complete (shutdown_broker (broker , args .shutdown_timeout ))
215
213
216
214
217
215
def watch_workers_restarts (args : TaskiqArgs ) -> None :
You can’t perform that action at this time.
0 commit comments