make transport send compatible with agent emit funcs

Author: dkolas

src/steamship/experimental/transports/steamship_widget.py

@@ -1,5 +1,5 @@
 import uuid
-from typing import Optional
+from typing import Any, Dict, Optional
 
 from steamship import Block, SteamshipError
 from steamship.experimental.transports.transport import Transport
@@ -17,7 +17,7 @@ def _instance_deinit(self, *args, **kwargs):
         """Unsubscribe from updates."""
         pass
 
-    def _send(self, blocks: [Block]):
+    def _send(self, blocks: [Block], metadata: Dict[str, Any]):
         """Send a response to the client.
 
         TODO: Since this isn't a push, but rather an API return, we need to figure out how to model this.

src/steamship/experimental/transports/telegram.py

@@ -1,6 +1,6 @@
 import logging
 import tempfile
-from typing import Optional
+from typing import Any, Dict, Optional
 
 import requests
 
@@ -46,7 +46,7 @@ def _instance_deinit(self, *args, **kwargs):
         """Unsubscribe from Telegram updates."""
         requests.get(f"{self.api_root}/deleteWebhook")
 
-    def _send(self, blocks: [Block]):
+    def _send(self, blocks: [Block], metadata: Dict[str, Any]):
         """Send a response to the Telegram chat."""
         for block in blocks:
             chat_id = block.chat_id

src/steamship/experimental/transports/transport.py

@@ -1,7 +1,7 @@
 import logging
 import time
 from abc import ABC, abstractmethod
-from typing import List, Optional
+from typing import Any, Dict, List, Optional
 
 from steamship import Block
 
@@ -69,7 +69,7 @@ def send(self, blocks: List[Block]):
         )
 
     @abstractmethod
-    def _send(self, blocks: List[Block]):
+    def _send(self, blocks: List[Block], metadata: Dict[str, Any]):
         raise NotImplementedError
 
     def parse_inbound(self, payload: dict, context: Optional[dict] = None) -> Optional[Block]: