Merge branch 'dev' of https://github.com/Azure/azure-functions-python-library into hallvictoria/simplified-mcp-decorator

hallvictoria · hallvictoria · commit 6210130ee87c · 2025-11-03T15:02:13.000-06:00
diff --git a/.azuredevops/dependabot.yml b/.azuredevops/dependabot.yml
@@ -0,0 +1,4 @@
+# Mirrored repository. We use dependabot via GitHub, not Azure DevOps.
+version: 2
+enable-security-updates: false
+enable-campaigned-updates: false
diff --git a/README.md b/README.md
@@ -7,16 +7,15 @@
 
 ## Overview
 
-Python support for Azure Functions is based on Python 3.8, 3.9, 3.10, 3.11, and 3.12 serverless hosting on Linux, and the Functions 2.x ([EOL](https://learn.microsoft.com/azure/azure-functions/functions-versions?#retired-versions)), 3.x ([EOL](https://learn.microsoft.com/azure/azure-functions/functions-versions?#retired-versions)) and 4.0 runtime.
+Python support for Azure Functions is based on Python 3.10, 3.11, 3.12, and 3.13 serverless hosting on Linux, and the Functions 2.x ([EOL](https://learn.microsoft.com/azure/azure-functions/functions-versions?#retired-versions)), 3.x ([EOL](https://learn.microsoft.com/azure/azure-functions/functions-versions?#retired-versions)) and 4.0 runtime.
 
 Here is the current status of Python in Azure Functions:
 
 _What are the supported Python versions?_
 
-| Azure Functions Runtime | Python 3.8                                                                           | Python 3.9                                                                           | Python 3.10 | Python 3.11 | Python 3.12 |
-|-------------------------|--------------------------------------------------------------------------------------|--------------------------------------------------------------------------------------|-------------|-------------|-------------|
-| Azure Functions 3.0     | [EOL](https://learn.microsoft.com/azure/azure-functions/migrate-version-3-version-4) | [EOL](https://learn.microsoft.com/azure/azure-functions/migrate-version-3-version-4) | -           | -           | -           |
-| Azure Functions 4.0     | &#x2713;                                                                             | &#x2713;                                                                             | &#x2713;    | &#x2713;    | &#x2713;    |
+| Azure Functions Runtime          | Python 3.10 | Python 3.11 | Python 3.12 | Python 3.13 |
+|----------------------------------|------------|------------|-------------|-------------|
+| Azure Functions 4.0              | ✔          | ✔          | ✔           | ✔           |                                                                              | &#x2713;    | &#x2713;    | &#x2713;    |
 
 _What's available?_
 - Build, test, debug and publish using Azure Functions Core Tools (CLI) or Visual Studio Code
diff --git a/azure/functions/decorators/function_app.py b/azure/functions/decorators/function_app.py
@@ -676,6 +676,7 @@ def service_bus_queue_trigger(
             access_rights: Optional[Union[AccessRights, str]] = None,
             is_sessions_enabled: Optional[bool] = None,
             cardinality: Optional[Union[Cardinality, str]] = None,
+            auto_complete_messages: Optional[bool] = None,
             **kwargs: Any) -> Callable[..., Any]:
         """
         The `on_service_bus_queue_change` decorator adds :class:`ServiceBusQueueTrigger` to the
@@ -700,6 +701,8 @@ def service_bus_queue_trigger(
         :param is_sessions_enabled: Set to True if connecting to a session-aware queue
             or subscription.
         :param cardinality: Set to "many" to enable batching.
+        :param auto_complete_messages: Indicates whether the message should be automatically
+            completed.
 
         :return: Decorator function.
         """
@@ -720,6 +723,7 @@ def decorator():
                         is_sessions_enabled=is_sessions_enabled,
                         cardinality=parse_singular_param_to_enum(cardinality,
                                                                  Cardinality),
+                        auto_complete_messages=auto_complete_messages,
                         **kwargs))
                 return fb
 
@@ -737,6 +741,7 @@ def service_bus_topic_trigger(
             access_rights: Optional[Union[AccessRights, str]] = None,
             is_sessions_enabled: Optional[bool] = None,
             cardinality: Optional[Union[Cardinality, str]] = None,
+            auto_complete_messages: Optional[bool] = None,
             **kwargs: Any) -> Callable[..., Any]:
         """
         The `on_service_bus_topic_change` decorator adds :class:`ServiceBusTopicTrigger` to the
@@ -762,6 +767,8 @@ def service_bus_topic_trigger(
         :param is_sessions_enabled: Set to True if connecting to a session-aware queue
             or subscription.
         :param cardinality: Set to "many" to enable batching.
+        :param auto_complete_messages: Indicates whether the message should be automatically
+            completed.
 
         :return: Decorator function.
         """
@@ -783,6 +790,7 @@ def decorator():
                         is_sessions_enabled=is_sessions_enabled,
                         cardinality=parse_singular_param_to_enum(cardinality,
                                                                  Cardinality),
+                        auto_complete_messages=auto_complete_messages,
                         **kwargs))
                 return fb
 
diff --git a/azure/functions/mysql.py b/azure/functions/mysql.py
@@ -76,3 +76,8 @@ def encode(cls, obj: typing.Any, *,
             type='json',
             value=json.dumps([dict(d) for d in data])
         )
+
+
+class MySqlTriggerConverter(MySqlConverter,
+                            binding='mysqlTrigger', trigger=True):
+    pass
diff --git a/eng/templates/jobs/build.yml b/eng/templates/jobs/build.yml
@@ -18,6 +18,8 @@ jobs:
           PYTHON_VERSION: '3.12'
         Python313:
           PYTHON_VERSION: '3.13'
+        Python314:
+          PYTHON_VERSION: '3.14'
           
     steps:
       - task: UsePythonVersion@0
diff --git a/eng/templates/jobs/ci-tests.yml b/eng/templates/jobs/ci-tests.yml
@@ -18,6 +18,8 @@ jobs:
           PYTHON_VERSION: '3.12'
         python-313:
           PYTHON_VERSION: '3.13'
+        python-314:
+          PYTHON_VERSION: '3.14'
           
     steps:
       - task: UsePythonVersion@0
diff --git a/tests/decorators/test_servicebus.py b/tests/decorators/test_servicebus.py
@@ -35,6 +35,31 @@ def test_service_bus_queue_trigger_valid_creation(self):
             "cardinality": Cardinality.ONE
         })
 
+    def test_service_bus_queue_trigger_autocomplete_valid_creation(self):
+        trigger = ServiceBusQueueTrigger(name="req", connection="dummy_conn",
+                                         queue_name="dummy_queue",
+                                         data_type=DataType.UNDEFINED,
+                                         access_rights=AccessRights.MANAGE,
+                                         is_sessions_enabled=True,
+                                         cardinality=Cardinality.ONE,
+                                         auto_complete_messages=True,
+                                         dummy_field="dummy")
+
+        self.assertEqual(trigger.get_binding_name(), "serviceBusTrigger")
+        self.assertEqual(trigger.get_dict_repr(), {
+            "type": SERVICE_BUS_TRIGGER,
+            "direction": BindingDirection.IN,
+            'dummyField': 'dummy',
+            "name": "req",
+            "connection": "dummy_conn",
+            "queueName": "dummy_queue",
+            "dataType": DataType.UNDEFINED,
+            "accessRights": AccessRights.MANAGE,
+            "isSessionsEnabled": True,
+            "cardinality": Cardinality.ONE,
+            "autoCompleteMessages": True
+        })
+
     def test_service_bus_queue_output_valid_creation(self):
         service_bus_queue_output = ServiceBusQueueOutput(
             name="res",
@@ -82,6 +107,33 @@ def test_service_bus_topic_trigger_valid_creation(self):
             "cardinality": Cardinality.ONE
         })
 
+    def test_service_bus_topic_trigger_autocomplete_valid_creation(self):
+        trigger = ServiceBusTopicTrigger(name="req", connection="dummy_conn",
+                                         topic_name="dummy_topic",
+                                         subscription_name="dummy_sub",
+                                         data_type=DataType.UNDEFINED,
+                                         access_rights=AccessRights.MANAGE,
+                                         is_sessions_enabled=True,
+                                         cardinality=Cardinality.ONE,
+                                         auto_complete_messages=True,
+                                         dummy_field="dummy")
+
+        self.assertEqual(trigger.get_binding_name(), "serviceBusTrigger")
+        self.assertEqual(trigger.get_dict_repr(), {
+            "type": SERVICE_BUS_TRIGGER,
+            "direction": BindingDirection.IN,
+            'dummyField': 'dummy',
+            "name": "req",
+            "connection": "dummy_conn",
+            "topicName": "dummy_topic",
+            "subscriptionName": "dummy_sub",
+            "dataType": DataType.UNDEFINED,
+            "accessRights": AccessRights.MANAGE,
+            "isSessionsEnabled": True,
+            "cardinality": Cardinality.ONE,
+            "autoCompleteMessages": True
+        })
+
     def test_service_bus_topic_output_valid_creation(self):
         output = ServiceBusTopicOutput(name="res", connection="dummy_conn",
                                        topic_name="dummy_topic",
diff --git a/tests/test_http_asgi.py b/tests/test_http_asgi.py
@@ -265,9 +265,11 @@ async def main(req, context):
         app.response_code = 200
         req = self._generate_func_request()
         ctx = self._generate_func_context()
-        response = asyncio.get_event_loop().run_until_complete(
-            AsgiMiddleware(app).handle_async(req, ctx)
-        )
+
+        async def run_test():
+            return await AsgiMiddleware(app).handle_async(req, ctx)
+
+        response = asyncio.run(run_test())
 
         # Verify asserted
         self.assertEqual(response.status_code, 200)
@@ -276,15 +278,15 @@ async def main(req, context):
     def test_function_app_lifecycle_events(self):
         mock_app = MockAsgiApplication()
         middleware = AsgiMiddleware(mock_app)
-        asyncio.get_event_loop().run_until_complete(
-            middleware.notify_startup()
-        )
-        assert mock_app.startup_called
 
-        asyncio.get_event_loop().run_until_complete(
-            middleware.notify_shutdown()
-        )
-        assert mock_app.shutdown_called
+        async def run_test():
+            await middleware.notify_startup()
+            assert mock_app.startup_called
+
+            await middleware.notify_shutdown()
+            assert mock_app.shutdown_called
+
+        asyncio.run(run_test())
 
     def test_function_app_lifecycle_events_with_failures(self):
         apps = [
@@ -295,22 +297,24 @@ def test_function_app_lifecycle_events_with_failures(self):
             MockAsgiApplication(False, "bork"),
             MockAsgiApplication("bork", "bork"),
         ]
-        for mock_app in apps:
+
+        async def run_test(mock_app):
             middleware = AsgiMiddleware(mock_app)
-            asyncio.get_event_loop().run_until_complete(
-                middleware.notify_startup()
-            )
+            await middleware.notify_startup()
             assert mock_app.startup_called
 
-            asyncio.get_event_loop().run_until_complete(
-                middleware.notify_shutdown()
-            )
+            await middleware.notify_shutdown()
             assert mock_app.shutdown_called
 
+        for mock_app in apps:
+            asyncio.run(run_test(mock_app))
+
     def test_calling_shutdown_without_startup_errors(self):
         mock_app = MockAsgiApplication()
         middleware = AsgiMiddleware(mock_app)
+
+        async def run_test():
+            await middleware.notify_shutdown()
+
         with pytest.raises(RuntimeError):
-            asyncio.get_event_loop().run_until_complete(
-                middleware.notify_shutdown()
-            )
+            asyncio.run(run_test())

Original file line number	Diff line number	Diff line change
`@@ -76,3 +76,8 @@ def encode(cls, obj: typing.Any, *,`
`76`	`76`	`type='json',`
`77`	`77`	`value=json.dumps([dict(d) for d in data])`
`78`	`78`	`)`
	`79`	`+`
	`80`	`+`
	`81`	`+class MySqlTriggerConverter(MySqlConverter,`
	`82`	`+ binding='mysqlTrigger', trigger=True):`
	`83`	`+ pass`