Satisfy pep8 warnings

Author: Matt Curtis

fdk/__init__.py

@@ -28,7 +28,7 @@
 
 def start(handle_code: customer_code.Function,
           uds: str,
-          loop: asyncio.AbstractEventLoop=None):
+          loop: asyncio.AbstractEventLoop = None):
     """
     Unix domain socket HTTP server entry point
     :param handle_code: customer's code

fdk/async_http/response.py

@@ -117,7 +117,7 @@ def get_headers(
 
         headers = self._parse_headers()
 
-        if self.status is 200:
+        if self.status == 200:
             status = b"OK"
         else:
             status = STATUS_CODES.get(self.status)
@@ -227,7 +227,7 @@ def output(self, version="1.1", keep_alive=False, keep_alive_timeout=None):
 
         headers = self._parse_headers()
 
-        if self.status is 200:
+        if self.status == 200:
             status = b"OK"
         else:
             status = STATUS_CODES.get(self.status, b"UNKNOWN RESPONSE")

fdk/context.py

@@ -118,9 +118,9 @@ def Method(self):
         return self._method
 
     def __is_gateway(self):
-        return (constants.FN_INTENT in self.__headers and
-                self.__headers.get(constants.FN_INTENT) ==
-                constants.INTENT_HTTP_REQUEST)
+        return (constants.FN_INTENT in self.__headers
+                and self.__headers.get(constants.FN_INTENT)
+                == constants.INTENT_HTTP_REQUEST)
 
 
 def context_from_format(format_def: str, **kwargs) -> (

fdk/headers.py

@@ -62,8 +62,8 @@ def encap_headers(headers, status=None):
             k = k.lower()
             if k.startswith(constants.FN_HTTP_PREFIX):  # by default merge
                 push_header(new_headers, k, v)
-            if (k == constants.CONTENT_TYPE or
-                    k == constants.FN_FDK_VERSION):  # but don't merge these
+            if (k == constants.CONTENT_TYPE
+                    or k == constants.FN_FDK_VERSION):  # but don't merge these
                 new_headers[k] = v
             else:
                 push_header(new_headers, constants.FN_HTTP_PREFIX + k, v)

fdk/response.py

@@ -20,10 +20,10 @@
 class Response(object):
 
     def __init__(self, ctx: context.InvokeContext,
-                 response_data: Union[str, bytes]=None,
-                 headers: dict=None,
-                 status_code: int=200,
-                 response_encoding: str="utf-8"):
+                 response_data: Union[str, bytes] = None,
+                 headers: dict = None,
+                 status_code: int = 200,
+                 response_encoding: str = "utf-8"):
         """
         Creates an FDK-readable response object
         :param ctx: invoke context

fdk/tests/tcp_debug.py

@@ -23,7 +23,7 @@
 from fdk.async_http import router
 
 
-def handle(handle_code: customer_code.Function, port: int=5000):
+def handle(handle_code: customer_code.Function, port: int = 5000):
     """
     FDK entry point
     :param handle_code: customer's code

samples/echo/func.py

@@ -20,7 +20,7 @@
 from fdk import response
 
 
-def handler(ctx, data: io.BytesIO=None):
+def handler(ctx, data: io.BytesIO = None):
     name = "World"
     try:
         body = json.loads(data.getvalue())