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