Lint files

Author: jverce

src/pipedream/client.py

@@ -6,11 +6,11 @@
 import typing
 
 import httpx
-from .types.project_environment import ProjectEnvironment
 from .core.api_error import ApiError
 from .core.client_wrapper import AsyncClientWrapper, SyncClientWrapper
 from .core.oauth_token_provider import OAuthTokenProvider
 from .environment import PipedreamEnvironment
+from .types.project_environment import ProjectEnvironment
 
 if typing.TYPE_CHECKING:
     from .accounts.client import AccountsClient, AsyncAccountsClient

src/pipedream/proxy/client.py

@@ -108,6 +108,7 @@ def _stream() -> typing.Iterator[bytes]:
                     yield chunk
             finally:
                 ctx.__exit__(None, None, None)
+
         return _stream()
 
     def post(
@@ -196,6 +197,7 @@ def _stream() -> typing.Iterator[bytes]:
                     yield chunk
             finally:
                 ctx.__exit__(None, None, None)
+
         return _stream()
 
     def put(
@@ -284,6 +286,7 @@ def _stream() -> typing.Iterator[bytes]:
                     yield chunk
             finally:
                 ctx.__exit__(None, None, None)
+
         return _stream()
 
     def delete(
@@ -363,6 +366,7 @@ def _stream() -> typing.Iterator[bytes]:
                     yield chunk
             finally:
                 ctx.__exit__(None, None, None)
+
         return _stream()
 
     def patch(
@@ -451,6 +455,7 @@ def _stream() -> typing.Iterator[bytes]:
                     yield chunk
             finally:
                 ctx.__exit__(None, None, None)
+
         return _stream()
 
 
@@ -557,6 +562,7 @@ async def _stream() -> typing.AsyncIterator[bytes]:
                     yield chunk
             finally:
                 await ctx.__aexit__(None, None, None)
+
         return _stream()
 
     async def post(
@@ -653,6 +659,7 @@ async def _stream() -> typing.AsyncIterator[bytes]:
                     yield chunk
             finally:
                 await ctx.__aexit__(None, None, None)
+
         return _stream()
 
     async def put(
@@ -749,6 +756,7 @@ async def _stream() -> typing.AsyncIterator[bytes]:
                     yield chunk
             finally:
                 await ctx.__aexit__(None, None, None)
+
         return _stream()
 
     async def delete(
@@ -836,6 +844,7 @@ async def _stream() -> typing.AsyncIterator[bytes]:
                     yield chunk
             finally:
                 await ctx.__aexit__(None, None, None)
+
         return _stream()
 
     async def patch(
@@ -932,4 +941,5 @@ async def _stream() -> typing.AsyncIterator[bytes]:
                     yield chunk
             finally:
                 await ctx.__aexit__(None, None, None)
+
         return _stream()