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 55
66
77class JSONSerializer (TaskiqSerializer ):
8- """Default taskiq serizalizer ."""
8+ """Default taskiq serializer ."""
99
1010 def __init__ (self , default : Optional [Callable [..., None ]] = None ) -> None :
1111 self .default = default
@@ -14,7 +14,7 @@ def dumpb(self, value: Any) -> bytes:
1414 """
1515 Dumps taskiq message to some broker message format.
1616
17- :param message : message to send.
17+ :param value : message to send.
1818 :return: Dumped message.
1919 """
2020 return dumps (
@@ -26,7 +26,7 @@ def loadb(self, value: bytes) -> Any:
2626 """
2727 Parse byte-encoded value received from the wire.
2828
29- :param message : value to parse.
29+ :param value : value to parse.
3030 :return: decoded value.
3131 """
3232 return loads (value .decode ())
You can’t perform that action at this time.
0 commit comments