File tree Expand file tree Collapse file tree 2 files changed +11
-8
lines changed Expand file tree Collapse file tree 2 files changed +11
-8
lines changed Original file line number Diff line number Diff line change @@ -128,6 +128,8 @@ def run_worker(args: WorkerArgs) -> None: # noqa: WPS213
128128 and joins them all.
129129
130130 :param args: CLI arguments.
131+
132+ :raises ValueError: if reload flag is used, but dependencies are not installed.
131133 """
132134 logging .basicConfig (
133135 level = logging .getLevelName (args .log_level ),
@@ -137,10 +139,12 @@ def run_worker(args: WorkerArgs) -> None: # noqa: WPS213
137139 logger .info ("Starting %s worker processes." , args .workers )
138140
139141 observer = None
140- if Observer is not None :
141- observer = Observer ()
142142
143- if observer is not None and args .reload :
143+ if args .reload and Observer is None :
144+ raise ValueError ("To use '--reload' flag, please install 'taskiq[reload]'." )
145+
146+ if Observer is not None and args .reload :
147+ observer = Observer ()
144148 observer .start ()
145149 args .workers = 1
146150 logging .warning (
Original file line number Diff line number Diff line change @@ -57,11 +57,10 @@ def __init__(
5757 Histogram ,
5858 start_http_server ,
5959 )
60- except ImportError :
61- logger .warn (
62- "Cannot initialize metrics. Please install 'taskiq[metrics]' extra." ,
63- )
64- raise
60+ except ImportError as exc :
61+ raise ImportError (
62+ "Cannot initialize metrics. Please install 'taskiq[metrics]'." ,
63+ ) from exc
6564
6665 self .found_errors = Counter (
6766 "found_errors" ,
You can’t perform that action at this time.
0 commit comments