We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 14611af commit 285b1d6Copy full SHA for 285b1d6
1 file changed
taskiq_nats/broker.py
@@ -28,7 +28,7 @@ class NatsBroker(AsyncBroker):
28
def __init__( # noqa: WPS211 (too many args)
29
self,
30
servers: Union[str, List[str]],
31
- subject: str = "tasiq_tasks",
+ subject: str = "taskiq_tasks",
32
queue: Optional[str] = None,
33
result_backend: "Optional[AsyncResultBackend[_T]]" = None,
34
task_id_generator: Optional[Callable[[], str]] = None,
0 commit comments