diff options
author | Alex Grönholm <alex.gronholm@nextday.fi> | 2022-04-20 01:00:57 +0300 |
---|---|---|
committer | Alex Grönholm <alex.gronholm@nextday.fi> | 2022-04-20 01:11:20 +0300 |
commit | b20f62d929eed84ad18020bb82dd43d8cb70da4d (patch) | |
tree | c42bf1877dd54755c55c649269e1254995bdf0c9 /src/apscheduler/serializers | |
parent | 82992cd427a9ab2351d8e0719b82d826dff5a521 (diff) | |
download | apscheduler-b20f62d929eed84ad18020bb82dd43d8cb70da4d.tar.gz |
Switched to Black for code formatting
Diffstat (limited to 'src/apscheduler/serializers')
-rw-r--r-- | src/apscheduler/serializers/cbor.py | 10 | ||||
-rw-r--r-- | src/apscheduler/serializers/json.py | 14 |
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) |