Skip to content

Commit 6b20827

Browse files
oromogansoromogans
committed
rename typo
1 parent 8f97d38 commit 6b20827

File tree

6 files changed

+29
-25
lines changed

6 files changed

+29
-25
lines changed

‎taskiq/queue.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
import dataclasses
44

5-
DEFAULT_QUEUE = "taksiq"
5+
DEFAULT_QUEUE = "taskiq"
66

77

88
@dataclasses.dataclass(frozen=True, init=False, eq=True)

‎tests/cli/worker/test_parameters_parsing.py‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ def test_parse_params_no_signature() -> None:
2525
task_id="",
2626
task_name="",
2727
labels={},
28-
queue="taksiq",
28+
queue="taskiq",
2929
args=[1, 2],
3030
kwargs={"a": 1},
3131
)
@@ -50,7 +50,7 @@ def test_func(param: test_class) -> test_class: # type: ignore
5050
task_id="",
5151
task_name="",
5252
labels={},
53-
queue="taksiq",
53+
queue="taskiq",
5454
args=[{"field": "test_val"}],
5555
kwargs={},
5656
)
@@ -68,7 +68,7 @@ def test_func(param: test_class) -> test_class: # type: ignore
6868
task_id="",
6969
task_name="",
7070
labels={},
71-
queue="taksiq",
71+
queue="taskiq",
7272
args=[],
7373
kwargs={"param": {"field": "test_val"}},
7474
)
@@ -94,7 +94,7 @@ def test_func(param: test_class) -> test_class: # type: ignore
9494
task_id="",
9595
task_name="",
9696
labels={},
97-
queue="taksiq",
97+
queue="taskiq",
9898
args=[{"unknown": "unknown"}],
9999
kwargs={},
100100
)
@@ -111,7 +111,7 @@ def test_func(param: test_class) -> test_class: # type: ignore
111111
task_id="",
112112
task_name="",
113113
labels={},
114-
queue="taksiq",
114+
queue="taskiq",
115115
args=[],
116116
kwargs={"param": {"unknown": "unknown"}},
117117
)
@@ -135,7 +135,7 @@ def test_func(param: test_class) -> test_class: # type: ignore
135135
msg_with_args = TaskiqMessage(
136136
task_id="",
137137
task_name="",
138-
queue="taksiq",
138+
queue="taskiq",
139139
labels={},
140140
args=[None],
141141
kwargs={},
@@ -148,7 +148,7 @@ def test_func(param: test_class) -> test_class: # type: ignore
148148
msg_with_kwargs = TaskiqMessage(
149149
task_id="",
150150
task_name="",
151-
queue="taksiq",
151+
queue="taskiq",
152152
labels={},
153153
args=[],
154154
kwargs={"param": None},

‎tests/depends/test_progress_tracker.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ def get_message(
5151
task_id=task_id or task.broker.id_generator(),
5252
task_name=task.task_name,
5353
labels=labels,
54-
queue="taksiq",
54+
queue="taskiq",
5555
args=list(args),
5656
kwargs=kwargs,
5757
)

‎tests/formatters/test_json_formatter.py‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -12,17 +12,18 @@ async def test_json_dumps() -> None:
1212
msg = TaskiqMessage(
1313
task_id="task-id",
1414
task_name="task.name",
15-
queue="taksiq",
15+
queue="taskiq",
1616
labels={"label1": 1, "label2": "text"},
1717
args=[1, "a"],
1818
kwargs={"p1": "v1"},
1919
)
2020
expected = BrokerMessage(
2121
task_id="task-id",
2222
task_name="task.name",
23-
queue="taksiq",
23+
queue="taskiq",
2424
message=(
2525
b'{"task_id":"task-id","task_name":"task.name",'
26+
b'"queue": "taskiq",'
2627
b'"labels":{"label1":1,"label2":"text"},'
2728
b'"labels_types":null,'
2829
b'"args":[1,"a"],"kwargs":{"p1":"v1"}}'
@@ -41,14 +42,15 @@ async def test_json_loads() -> None:
4142
fmt = JSONFormatter()
4243
msg = (
4344
b'{"task_id":"task-id","task_name":"task.name",'
45+
b'"queue": "taskiq",'
4446
b'"labels":{"label1":1,"label2":"text"},'
4547
b'"args":[1,"a"],"kwargs":{"p1":"v1"}}'
4648
)
4749
expected = TaskiqMessage(
4850
task_id="task-id",
4951
task_name="task.name",
5052
labels={"label1": 1, "label2": "text"},
51-
queue="taksiq",
53+
queue="taskiq",
5254
args=[1, "a"],
5355
kwargs={"p1": "v1"},
5456
)

‎tests/formatters/test_proxy_formatter.py‎

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ async def test_proxy_dumps() -> None:
1111
msg = TaskiqMessage(
1212
task_id="task-id",
1313
task_name="task.name",
14-
queue="taksiq",
14+
queue="taskiq",
1515
labels={"label1": 1, "label2": "text"},
1616
args=[1, "a"],
1717
kwargs={"p1": "v1"},
@@ -22,6 +22,7 @@ async def test_proxy_dumps() -> None:
2222
queue="taskiq",
2323
message=(
2424
b'{"task_id": "task-id", "task_name": "task.name", '
25+
b'"queue": "taskiq", '
2526
b'"labels": {"label1": 1, "label2": "text"}, '
2627
b'"labels_types": null, '
2728
b'"args": [1, "a"], "kwargs": {"p1": "v1"}}'
@@ -37,6 +38,7 @@ async def test_proxy_loads() -> None:
3738
broker = InMemoryBroker()
3839
msg = (
3940
b'{"task_id":"task-id","task_name":"task.name",'
41+
b'"queue": "taskiq", '
4042
b'"labels":{"label1":1,"label2":"text"},'
4143
b'"args":[1,"a"],"kwargs":{"p1":"v1"}}'
4244
)

‎tests/receiver/test_receiver.py‎

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ async def test_func(param: int) -> int:
5555
task_id="",
5656
task_name="",
5757
labels={},
58-
queue="taksiq",
58+
queue="taskiq",
5959
args=[1],
6060
kwargs={},
6161
),
@@ -78,7 +78,7 @@ def test_func(param: int) -> int:
7878
TaskiqMessage(
7979
task_id="",
8080
task_name="",
81-
queue="taksiq",
81+
queue="taskiq",
8282
labels={},
8383
args=[1],
8484
kwargs={},
@@ -101,7 +101,7 @@ def test_func() -> None:
101101
TaskiqMessage(
102102
task_id="",
103103
task_name="",
104-
queue="taksiq",
104+
queue="taskiq",
105105
labels={},
106106
args=[],
107107
kwargs={},
@@ -123,7 +123,7 @@ async def test_func() -> None:
123123
TaskiqMessage(
124124
task_id="",
125125
task_name="",
126-
queue="taksiq",
126+
queue="taskiq",
127127
labels={"timeout": "0.3"},
128128
args=[],
129129
kwargs={},
@@ -146,7 +146,7 @@ def test_func() -> None:
146146
TaskiqMessage(
147147
task_id="",
148148
task_name="",
149-
queue="taksiq",
149+
queue="taskiq",
150150
labels={"timeout": "0.3"},
151151
args=[],
152152
kwargs={},
@@ -183,7 +183,7 @@ def test_func() -> None:
183183
TaskiqMessage(
184184
task_id="",
185185
task_name="",
186-
queue="taksiq",
186+
queue="taskiq",
187187
labels={},
188188
args=[],
189189
kwargs={},
@@ -213,7 +213,7 @@ async def my_task() -> int:
213213
TaskiqMessage(
214214
task_id="task_id",
215215
task_name=my_task.task_name,
216-
queue="taksiq",
216+
queue="taskiq",
217217
labels={},
218218
args=[],
219219
kwargs={},
@@ -249,7 +249,7 @@ async def my_task(dep: int = Depends(dependency)) -> None:
249249
TaskiqMessage(
250250
task_id="task_id",
251251
task_name=my_task.task_name,
252-
queue="taksiq",
252+
queue="taskiq",
253253
labels={},
254254
args=[],
255255
kwargs={},
@@ -283,7 +283,7 @@ def ack_callback() -> None:
283283
TaskiqMessage(
284284
task_id="task_id",
285285
task_name=my_task.task_name,
286-
queue="taksiq",
286+
queue="taskiq",
287287
labels={},
288288
args=[],
289289
kwargs={},
@@ -323,7 +323,7 @@ async def ack_callback() -> None:
323323
TaskiqMessage(
324324
task_id="task_id",
325325
task_name=my_task.task_name,
326-
queue="taksiq",
326+
queue="taskiq",
327327
labels={},
328328
args=[],
329329
kwargs={},
@@ -360,7 +360,7 @@ async def test_callback_unknown_task() -> None:
360360
TaskiqMessage(
361361
task_id="task_id",
362362
task_name="unknown",
363-
queue="taksiq",
363+
queue="taskiq",
364364
labels={},
365365
args=[],
366366
kwargs={},
@@ -398,7 +398,7 @@ def test_func(tes_val: MyTestClass = Depends()) -> int:
398398
TaskiqMessage(
399399
task_id="",
400400
task_name=test_func.task_name,
401-
queue="taksiq",
401+
queue="taskiq",
402402
labels={},
403403
args=[],
404404
kwargs={},

0 commit comments

Comments
 (0)