File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 5
5
6
6
7
7
class JSONSerializer (TaskiqSerializer ):
8
- """Default taskiq serizalizer ."""
8
+ """Default taskiq serializer ."""
9
9
10
10
def __init__ (self , default : Optional [Callable [..., None ]] = None ) -> None :
11
11
self .default = default
@@ -14,7 +14,7 @@ def dumpb(self, value: Any) -> bytes:
14
14
"""
15
15
Dumps taskiq message to some broker message format.
16
16
17
- :param message : message to send.
17
+ :param value : message to send.
18
18
:return: Dumped message.
19
19
"""
20
20
return dumps (
@@ -26,7 +26,7 @@ def loadb(self, value: bytes) -> Any:
26
26
"""
27
27
Parse byte-encoded value received from the wire.
28
28
29
- :param message : value to parse.
29
+ :param value : value to parse.
30
30
:return: decoded value.
31
31
"""
32
32
return loads (value .decode ())
You can’t perform that action at this time.
0 commit comments