diff --git a/libraries/botbuilder-integration-aiohttp/botbuilder/integration/aiohttp/streaming/aiohttp_web_socket.py b/libraries/botbuilder-integration-aiohttp/botbuilder/integration/aiohttp/streaming/aiohttp_web_socket.py
index 334c637fb..2cd4ec13b 100644
--- a/libraries/botbuilder-integration-aiohttp/botbuilder/integration/aiohttp/streaming/aiohttp_web_socket.py
+++ b/libraries/botbuilder-integration-aiohttp/botbuilder/integration/aiohttp/streaming/aiohttp_web_socket.py
@@ -29,7 +29,7 @@ def __init__(
 
     def dispose(self):
         if self._session:
-            asyncio.create_task(self._session.close())
+            task = asyncio.create_task(self._session.close())
 
     async def close(self, close_status: WebSocketCloseStatus, status_description: str):
         await self._aiohttp_ws.close(
diff --git a/libraries/botframework-streaming/botframework/streaming/protocol_adapter.py b/libraries/botframework-streaming/botframework/streaming/protocol_adapter.py
index 71661bdf2..adee0c3a2 100644
--- a/libraries/botframework-streaming/botframework/streaming/protocol_adapter.py
+++ b/libraries/botframework-streaming/botframework/streaming/protocol_adapter.py
@@ -75,7 +75,7 @@ async def _on_receive_response(self, identifier: UUID, response: ReceiveResponse
 
     def _on_cancel_stream(self, content_stream_assembler: PayloadStreamAssembler):
         # TODO: on original C# code content_stream_assembler is typed as IAssembler
-        asyncio.create_task(
+        task = asyncio.create_task(
             self._send_operations.send_cancel_stream(
                 content_stream_assembler.identifier
             )