rename to connectors

Author: hallvictoria

azure/functions/__init__.py

@@ -22,7 +22,6 @@
 from ._http_asgi import AsgiMiddleware
 from .kafka import KafkaEvent, KafkaConverter, KafkaTriggerConverter
 from .mcp import MCPToolContext, PromptInvocationContext
-from .connector import ConnectorContext
 from .meta import get_binding_registry
 from ._queue import QueueMessage
 from ._servicebus import ServiceBusMessage
@@ -44,7 +43,7 @@
 from . import sql  # NoQA
 from . import warmup  # NoQA
 from . import mysql  # NoQA
-from . import connector  # NoQA
+from . import connectors  # NoQA
 
 
 __all__ = (
@@ -78,7 +77,6 @@
     'WarmUpContext',
     'MySqlRow',
     'MySqlRowList',
-    'ConnectorContext',
 
     # Middlewares
     'WsgiMiddleware',

azure/functions/connector.py azure/functions/connectors.pyazure/functions/connector.py renamed to azure/functions/connectors.py

@@ -6,17 +6,12 @@
 from . import meta
 
 
-class ConnectorContext(typing.Dict[str, typing.Any]):
-    """Context object for connector triggers."""
-    pass
-
-
 class ConnectorTriggerConverter(meta.InConverter, binding='connectorTrigger',
                                 trigger=True):
 
     @classmethod
     def check_input_type_annotation(cls, pytype: type) -> bool:
-        return issubclass(pytype, (str, dict, bytes, ConnectorContext))
+        return issubclass(pytype, (str, dict, bytes))
 
     @classmethod
     def has_implicit_output(cls) -> bool:

azure/functions/decorators/generic.py

@@ -46,18 +46,3 @@ def __init__(self,
                  data_type: Optional[DataType] = None,
                  **kwargs):
         super().__init__(name=name, data_type=data_type, type=type)
-
-
-class ConnectorTrigger(Trigger):
-
-    @staticmethod
-    def get_binding_name():
-        from azure.functions.decorators.constants import CONNECTOR_TRIGGER
-        return CONNECTOR_TRIGGER
-
-    def __init__(self,
-                 name: str,
-                 data_type: Optional[DataType] = None,
-                 **kwargs):
-        from azure.functions.decorators.constants import CONNECTOR_TRIGGER
-        super().__init__(name=name, data_type=data_type, type=CONNECTOR_TRIGGER)

tests/test_connector.py

@@ -4,8 +4,7 @@
 import json
 import azure.functions as func
 from azure.functions.meta import Datum
-from azure.functions.connector import (ConnectorTriggerConverter,
-                                       ConnectorContext)
+from azure.functions.connectors import ConnectorTriggerConverter
 
 
 class TestConnectorTriggerConverter(unittest.TestCase):
@@ -15,7 +14,6 @@ def test_check_input_type_annotation_valid_types(self):
         self.assertTrue(ConnectorTriggerConverter.check_input_type_annotation(str))
         self.assertTrue(ConnectorTriggerConverter.check_input_type_annotation(dict))
         self.assertTrue(ConnectorTriggerConverter.check_input_type_annotation(bytes))
-        self.assertTrue(ConnectorTriggerConverter.check_input_type_annotation(ConnectorContext))
 
     def test_check_input_type_annotation_invalid_type(self):
         with self.assertRaises(TypeError):
@@ -106,14 +104,6 @@ def test_encode_other_type(self):
         self.assertEqual(result.type, 'string')
         self.assertEqual(result.value, 'True')
 
-    def test_connector_context_is_dict_subclass(self):
-        # Verify ConnectorContext is a dict subclass
-        self.assertTrue(issubclass(ConnectorContext, dict))
-
-        # Test that it can be instantiated and used as a dict
-        ctx = ConnectorContext({'key': 'value'})
-        self.assertEqual(ctx['key'], 'value')
-
 
 class TestConnectorDecoratorIntegration(unittest.TestCase):
     """Integration tests for the connector trigger decorator"""