Skip to content

Commit af5439b

Browse files
author
Ilya Volnistov
committed
fix linting and formatting
1 parent 49875a6 commit af5439b

File tree

2 files changed

+7
-3
lines changed

2 files changed

+7
-3
lines changed

taskiq/cli/worker/args.py

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,9 @@ class WorkerArgs:
3030
fs_discover: bool = False
3131
configure_logging: bool = True
3232
log_level: LogLevel = LogLevel.INFO
33-
log_format: str = "[%(asctime)s][%(name)s][%(levelname)-7s][%(processName)s] %(message)s"
33+
log_format: str = (
34+
"[%(asctime)s][%(name)s][%(levelname)-7s][%(processName)s] %(message)s"
35+
)
3436
workers: int = 2
3537
max_threadpool_threads: Optional[int] = None
3638
max_process_pool_processes: Optional[int] = None
@@ -121,7 +123,8 @@ def from_cli(
121123
)
122124
parser.add_argument(
123125
"--log-format",
124-
default="[%(asctime)s][%(name)s][%(levelname)-7s][%(processName)s] %(message)s",
126+
default="[%(asctime)s][%(name)s][%(levelname)-7s]"
127+
"[%(processName)s] %(message)s",
125128
help="worker log format",
126129
)
127130
parser.add_argument(

taskiq/cli/worker/run.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@
55
import signal
66
import sys
77
from concurrent.futures import Executor, ProcessPoolExecutor, ThreadPoolExecutor
8-
from multiprocessing import set_start_method, get_start_method
8+
from multiprocessing import get_start_method, set_start_method
99
from sys import platform
1010
from typing import Any, Optional, Type
1111

@@ -91,6 +91,7 @@ def start_listen(args: WorkerArgs) -> None:
9191
level=logging.getLevelName(args.log_level),
9292
format=args.log_format,
9393
)
94+
9495
def interrupt_handler(signum: int, _frame: Any) -> None:
9596
"""
9697
Signal handler.

0 commit comments

Comments
 (0)