summaryrefslogtreecommitdiff
path: root/src/apscheduler/serializers
diff options
context:
space:
mode:
authorAlex Grönholm <alex.gronholm@nextday.fi>2022-04-20 01:00:57 +0300
committerAlex Grönholm <alex.gronholm@nextday.fi>2022-04-20 01:11:20 +0300
commitb20f62d929eed84ad18020bb82dd43d8cb70da4d (patch)
treec42bf1877dd54755c55c649269e1254995bdf0c9 /src/apscheduler/serializers
parent82992cd427a9ab2351d8e0719b82d826dff5a521 (diff)
downloadapscheduler-b20f62d929eed84ad18020bb82dd43d8cb70da4d.tar.gz
Switched to Black for code formatting
Diffstat (limited to 'src/apscheduler/serializers')
-rw-r--r--src/apscheduler/serializers/cbor.py10
-rw-r--r--src/apscheduler/serializers/json.py14
2 files changed, 14 insertions, 10 deletions
diff --git a/src/apscheduler/serializers/cbor.py b/src/apscheduler/serializers/cbor.py
index bb610c5..9791b77 100644
--- a/src/apscheduler/serializers/cbor.py
+++ b/src/apscheduler/serializers/cbor.py
@@ -16,15 +16,17 @@ class CBORSerializer(Serializer):
load_options: dict[str, Any] = attrs.field(factory=dict)
def __attrs_post_init__(self):
- self.dump_options.setdefault('default', self._default_hook)
- self.load_options.setdefault('tag_hook', self._tag_hook)
+ self.dump_options.setdefault("default", self._default_hook)
+ self.load_options.setdefault("tag_hook", self._tag_hook)
def _default_hook(self, encoder, value):
- if hasattr(value, '__getstate__'):
+ if hasattr(value, "__getstate__"):
marshalled = marshal_object(value)
encoder.encode(CBORTag(self.type_tag, marshalled))
else:
- raise CBOREncodeTypeError(f'cannot serialize type {value.__class__.__name__}')
+ raise CBOREncodeTypeError(
+ f"cannot serialize type {value.__class__.__name__}"
+ )
def _tag_hook(self, decoder, tag: CBORTag, shareable_index: int = None):
if tag.tag == self.type_tag:
diff --git a/src/apscheduler/serializers/json.py b/src/apscheduler/serializers/json.py
index 02ad12f..255c520 100644
--- a/src/apscheduler/serializers/json.py
+++ b/src/apscheduler/serializers/json.py
@@ -12,22 +12,24 @@ from ..marshalling import marshal_date, marshal_object, unmarshal_object
@attrs.define(kw_only=True, eq=False)
class JSONSerializer(Serializer):
- magic_key: str = '_apscheduler_json'
+ magic_key: str = "_apscheduler_json"
dump_options: dict[str, Any] = attrs.field(factory=dict)
load_options: dict[str, Any] = attrs.field(factory=dict)
def __attrs_post_init__(self):
- self.dump_options['default'] = self._default_hook
- self.load_options['object_hook'] = self._object_hook
+ self.dump_options["default"] = self._default_hook
+ self.load_options["object_hook"] = self._object_hook
def _default_hook(self, obj):
- if hasattr(obj, '__getstate__'):
+ if hasattr(obj, "__getstate__"):
cls_ref, state = marshal_object(obj)
return {self.magic_key: [cls_ref, state]}
elif isinstance(obj, datetime):
return marshal_date(obj)
- raise TypeError(f'Object of type {obj.__class__.__name__!r} is not JSON serializable')
+ raise TypeError(
+ f"Object of type {obj.__class__.__name__!r} is not JSON serializable"
+ )
def _object_hook(self, obj_state: dict[str, Any]):
if self.magic_key in obj_state:
@@ -37,7 +39,7 @@ class JSONSerializer(Serializer):
return obj_state
def serialize(self, obj) -> bytes:
- return dumps(obj, ensure_ascii=False, **self.dump_options).encode('utf-8')
+ return dumps(obj, ensure_ascii=False, **self.dump_options).encode("utf-8")
def deserialize(self, serialized: bytes):
return loads(serialized, **self.load_options)