Fix lint. Apparently, we can complain about formating issues, but a human has to fix them.

Signed-off-by: Evan Anderson <evan.k.anderson@gmail.com>

Author: evankanderson

cloudevents/sdk/event/base.py

@@ -13,7 +13,6 @@
 #    under the License.
 
 import base64
-import io
 import json
 import typing
 
@@ -194,7 +193,7 @@ def Set(self, key: str, value: object):
 
     def MarshalJSON(self, data_marshaller: types.MarshallerType) -> str:
         if data_marshaller is None:
-            data_marshaller = lambda x: x
+            data_marshaller = lambda x: x  # noqa: E731
         props = self.Properties()
         if "data" in props:
             data = data_marshaller(props.pop("data"))
@@ -217,7 +216,8 @@ def UnmarshalJSON(
 
         for name, value in raw_ce.items():
             if name == "data":
-                # Use the user-provided serializer, which may have customized JSON decoding
+                # Use the user-provided serializer, which may have customized
+                # JSON decoding
                 value = data_unmarshaller(json.dumps(value))
             if name == "data_base64":
                 value = data_unmarshaller(base64.b64decode(value))
@@ -227,21 +227,21 @@ def UnmarshalJSON(
     def UnmarshalBinary(
         self,
         headers: dict,
-        body: typing.Union[bytes,str],
+        body: typing.Union[bytes, str],
         data_unmarshaller: types.UnmarshallerType
     ):
         if 'ce-specversion' not in headers:
-            raise ValueError(f"Missing required attribute: 'specversion'")
+            raise ValueError("Missing required attribute: 'specversion'")
         for header, value in headers.items():
             header = header.lower()
             if header == "content-type":
                 self.SetContentType(value)
             elif header.startswith("ce-"):
                 self.Set(header[3:], value)
         self.Set("data", data_unmarshaller(body))
-        missing_attributes = self._ce_required_fields - self.Properties().keys()
-        if len(missing_attributes) > 0:
-            raise ValueError(f"Missing required attributes: {missing_attributes}")
+        missing_attrs = self._ce_required_fields - self.Properties().keys()
+        if len(missing_attrs) > 0:
+            raise ValueError(f"Missing required attributes: {missing_attrs}")
 
     def MarshalBinary(
             self,

cloudevents/sdk/http_events.py

@@ -12,25 +12,25 @@
 #    License for the specific language governing permissions and limitations
 #    under the License.
 
-import copy
 import datetime
 import json
-import io
 import typing
 import uuid
 
 from cloudevents.sdk import converters
 from cloudevents.sdk import marshaller
 from cloudevents.sdk import types
-from cloudevents.sdk.converters import binary
-from cloudevents.sdk.converters import structured
 
 from cloudevents.sdk.event import v03, v1
 
-_marshaller_by_format = {converters.TypeStructured: lambda x: x,
-                          converters.TypeBinary: json.dumps}
-_required_by_version = {"1.0": v1.Event._ce_required_fields,
-                         "0.3": v03.Event._ce_required_fields}
+_marshaller_by_format = {
+    converters.TypeStructured: lambda x: x,
+    converters.TypeBinary: json.dumps,
+}
+_required_by_version = {
+    "1.0": v1.Event._ce_required_fields,
+    "0.3": v03.Event._ce_required_fields,
+}
 _obj_by_version = {"1.0": v1.Event, "0.3": v03.Event}
 
 
@@ -61,7 +61,7 @@ def from_http(
         :type data: typing.IO
         :param headers: the HTTP headers
         :type headers: typing.Dict[str, str]
-        :param data_unmarshaller: A function to decode data into a python object.
+        :param data_unmarshaller: Function to decode data into a python object.
         :type data_unmarshaller: types.UnmarshallerType
         """
         if data_unmarshaller is None:
@@ -76,7 +76,11 @@ def from_http(
 
         return cls(attrs, event.data)
 
-    def __init__(self, attributes: typing.Dict[str, str], data: typing.Any = None):
+    def __init__(
+        self,
+        attributes: typing.Dict[str, str],
+        data: typing.Any = None
+    ):
         """
         Event Constructor
         :param attributes: a dict with HTTP headers
@@ -104,7 +108,8 @@ def __init__(self, attributes: typing.Dict[str, str], data: typing.Any = None):
         if self._attributes['specversion'] not in _required_by_version:
             raise ValueError(
                 f"Invalid specversion: {self._attributes['specversion']}")
-        # There is no good way to default 'source' and 'type', so this checks for those.
+        # There is no good way to default 'source' and 'type', so this
+        # checks for those (or any new required attributes).
         required_set = _required_by_version[self._attributes['specversion']]
         if not required_set <= self._attributes.keys():
             raise ValueError(
@@ -120,7 +125,7 @@ def to_http(
 
         :param format: constant specifying an encoding format
         :type format: str
-        :param data_unmarshaller: callable function used to read the data io object
+        :param data_unmarshaller: Function used to read the data to string.
         :type data_unmarshaller: types.UnmarshallerType
         :returns: (http_headers: dict, http_body: bytes or str)
         """
@@ -135,7 +140,8 @@ def to_http(
             event.Set(k, v)
         event.data = self.data
 
-        return marshaller.NewDefaultHTTPMarshaller().ToRequest(event, format, data_marshaller)
+        return marshaller.NewDefaultHTTPMarshaller().ToRequest(
+            event, format, data_marshaller)
 
     # Data access is handled via `.data` member
     # Attribute access is managed via Mapping type

cloudevents/sdk/types.py

@@ -19,5 +19,6 @@
 
 MarshallerType = typing.Optional[
     typing.Callable[[typing.Any], typing.Union[bytes, str]]]
-UnmarshallerType = typing.Optional[typing.Callable[[
-    typing.Union[bytes, str]], typing.Any]]
+UnmarshallerType = typing.Optional[
+    typing.Callable[
+        [typing.Union[bytes, str]], typing.Any]]