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
128
128
and joins them all.
129
129
130
130
:param args: CLI arguments.
131
+
132
+ :raises ValueError: if reload flag is used, but dependencies are not installed.
131
133
"""
132
134
logging .basicConfig (
133
135
level = logging .getLevelName (args .log_level ),
@@ -137,10 +139,12 @@ def run_worker(args: WorkerArgs) -> None: # noqa: WPS213
137
139
logger .info ("Starting %s worker processes." , args .workers )
138
140
139
141
observer = None
140
- if Observer is not None :
141
- observer = Observer ()
142
142
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 ()
144
148
observer .start ()
145
149
args .workers = 1
146
150
logging .warning (
Original file line number Diff line number Diff line change @@ -57,11 +57,10 @@ def __init__(
57
57
Histogram ,
58
58
start_http_server ,
59
59
)
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
65
64
66
65
self .found_errors = Counter (
67
66
"found_errors" ,
You can’t perform that action at this time.
0 commit comments