Azure.Communication.Email 1.1.0 - 2025-09-01 (#43090)

* generate

* fix linting error

* more linting

* fix pylint

* update version

* fixes

* addressed PR feedback, updated test recordings

* updated recordings

* set conn_str to not optional

* update recordings again with passed api_version

* add unknown words to cspell

* Address PR feedback

* fix lint/docs/mypy errors

* fix addl lint errors

* address PR feedback

* add back mistakenly removed files

* address PR feedback

* pass decode_url as true to get async auth policy

* remove unused namespaces from apiview-properties

* remove malgenerated apiview-properties.json in inner directory

* adding missing imports

* rerecord tests with Python 3.14

* add sanitizer for accept-encoding header

---------

Co-authored-by: Nate Kimball <[email protected]>
Co-authored-by: antisch <[email protected]>

Author: 3 people

sdk/communication/azure-communication-email/CHANGELOG.md

@@ -1,5 +1,13 @@
 # Release History
 
+## 1.1.0 (2025-09-01)
+
+### Features Added
+
+- Consumers can now provide a value for the `contentId` property when sending emails with attachments.
+  This allows consumers to reference attachments in the email body using the `cid` scheme. The `contentId` property can be set on the `EmailAttachment` object.
+- `EmailClient.begin_send` now supports an optional `operation_id` parameter.
+
 ## 1.0.1b1 (2024-08-28)
 
 ### Features Added

sdk/communication/azure-communication-email/apiview-properties.json

@@ -0,0 +1,7 @@
+{
+    "CrossLanguagePackageId": null,
+    "CrossLanguageDefinitionId": {
+        "azure.communication.email.EmailClient.begin_send": null,
+        "azure.communication.email.aio.EmailClient.begin_send": null
+    }
+}

sdk/communication/azure-communication-email/assets.json

@@ -2,5 +2,5 @@
   "AssetsRepo": "Azure/azure-sdk-assets",
   "AssetsRepoPrefixPath": "python",
   "TagPrefix": "python/communication/azure-communication-email",
-  "Tag": "python/communication/azure-communication-email_1fa1cede8e"
+  "Tag": "python/communication/azure-communication-email_bc87ad827a"
 }

sdk/communication/azure-communication-email/azure/communication/email/__init__.py

@@ -1,9 +1,32 @@
-# -------------------------------------------------------------------------
+# coding=utf-8
+# --------------------------------------------------------------------------
 # Copyright (c) Microsoft Corporation. All rights reserved.
-# Licensed under the MIT License. See License.txt in the project root for
-# license information.
+# Licensed under the MIT License. See License.txt in the project root for license information.
+# Code generated by Microsoft (R) AutoRest Code Generator.
+# Changes may cause incorrect behavior and will be lost if the code is regenerated.
 # --------------------------------------------------------------------------
+# pylint: disable=wrong-import-position
+
+from typing import TYPE_CHECKING
+
+if TYPE_CHECKING:
+    from ._patch import *  # pylint: disable=unused-wildcard-import
+
+from ._client import EmailClient  # type: ignore
+from ._version import VERSION
+
+__version__ = VERSION
+
+try:
+    from ._patch import __all__ as _patch_all
+    from ._patch import *
+except ImportError:
+    _patch_all = []
+from ._patch import patch_sdk as _patch_sdk
 
-from ._email_client import EmailClient
+__all__ = [
+    "EmailClient",
+]
+__all__.extend([p for p in _patch_all if p not in __all__])  # pyright: ignore
 
-__all__ = ["EmailClient"]
+_patch_sdk()

sdk/communication/azure-communication-email/azure/communication/email/_api_versions.py

@@ -10,6 +10,7 @@
 class ApiVersion(str, Enum, metaclass=CaseInsensitiveEnumMeta):
     V2023_03_31 = "2023-03-31"
     V2024_07_01_PREVIEW = "2024-07-01-preview"
+    V2025_09_01 = "2025-09-01"
 
 
-DEFAULT_VERSION = ApiVersion.V2024_07_01_PREVIEW
+DEFAULT_VERSION = ApiVersion.V2025_09_01

sdk/communication/azure-communication-email/azure/communication/email/_generated/_client.py renamed to sdk/communication/azure-communication-email/azure/communication/email/_client.py

@@ -7,30 +7,26 @@
 # --------------------------------------------------------------------------
 
 from copy import deepcopy
-from typing import Any, TYPE_CHECKING
+from typing import Any
+from typing_extensions import Self
 
 from azure.core import PipelineClient
+from azure.core.pipeline import policies
 from azure.core.rest import HttpRequest, HttpResponse
 
-from ._configuration import AzureCommunicationEmailServiceConfiguration
-from ._serialization import Deserializer, Serializer
-from .operations import EmailOperations
+from ._configuration import EmailClientConfiguration
+from ._operations import _EmailClientOperationsMixin
+from ._utils.serialization import Deserializer, Serializer
 
-if TYPE_CHECKING:
-    # pylint: disable=unused-import,ungrouped-imports
-    from typing import Dict
 
-
-class AzureCommunicationEmailService:  # pylint: disable=client-accepts-api-version-keyword
+class EmailClient(_EmailClientOperationsMixin):
     """Azure Communication Email Service.
 
-    :ivar email: EmailOperations operations
-    :vartype email: azure.communication.email.operations.EmailOperations
     :param endpoint: The communication resource, for example
      https://my-resource.communication.azure.com. Required.
     :type endpoint: str
-    :keyword api_version: Api Version. Default value is "2024-07-01-preview". Note that overriding
-     this default value may result in unsupported behavior.
+    :keyword api_version: Api Version. Default value is "2025-09-01". Note that overriding this
+     default value may result in unsupported behavior.
     :paramtype api_version: str
     :keyword int polling_interval: Default waiting time between two polls for LRO operations if no
      Retry-After header is present.
@@ -40,15 +36,32 @@ def __init__(  # pylint: disable=missing-client-constructor-parameter-credential
         self, endpoint: str, **kwargs: Any
     ) -> None:
         _endpoint = "{endpoint}"
-        self._config = AzureCommunicationEmailServiceConfiguration(endpoint=endpoint, **kwargs)
-        self._client = PipelineClient(base_url=_endpoint, config=self._config, **kwargs)
+        self._config = EmailClientConfiguration(endpoint=endpoint, **kwargs)
+
+        _policies = kwargs.pop("policies", None)
+        if _policies is None:
+            _policies = [
+                policies.RequestIdPolicy(**kwargs),
+                self._config.headers_policy,
+                self._config.user_agent_policy,
+                self._config.proxy_policy,
+                policies.ContentDecodePolicy(**kwargs),
+                self._config.redirect_policy,
+                self._config.retry_policy,
+                self._config.authentication_policy,
+                self._config.custom_hook_policy,
+                self._config.logging_policy,
+                policies.DistributedTracingPolicy(**kwargs),
+                policies.SensitiveHeaderCleanupPolicy(**kwargs) if self._config.redirect_policy else None,
+                self._config.http_logging_policy,
+            ]
+        self._client: PipelineClient = PipelineClient(base_url=_endpoint, policies=_policies, **kwargs)
 
         self._serialize = Serializer()
         self._deserialize = Deserializer()
         self._serialize.client_side_validation = False
-        self.email = EmailOperations(self._client, self._config, self._serialize, self._deserialize)
 
-    def send_request(self, request: HttpRequest, **kwargs: Any) -> HttpResponse:
+    def send_request(self, request: HttpRequest, *, stream: bool = False, **kwargs: Any) -> HttpResponse:
         """Runs the network request through the client's chained policies.
 
         >>> from azure.core.rest import HttpRequest
@@ -72,17 +85,14 @@ def send_request(self, request: HttpRequest, **kwargs: Any) -> HttpResponse:
         }
 
         request_copy.url = self._client.format_url(request_copy.url, **path_format_arguments)
-        return self._client.send_request(request_copy, **kwargs)
+        return self._client.send_request(request_copy, stream=stream, **kwargs)  # type: ignore
 
-    def close(self):
-        # type: () -> None
+    def close(self) -> None:
         self._client.close()
 
-    def __enter__(self):
-        # type: () -> AzureCommunicationEmailService
+    def __enter__(self) -> Self:
         self._client.__enter__()
         return self
 
-    def __exit__(self, *exc_details):
-        # type: (Any) -> None
+    def __exit__(self, *exc_details: Any) -> None:
         self._client.__exit__(*exc_details)

sdk/communication/azure-communication-email/azure/communication/email/_generated/_configuration.py renamed to sdk/communication/azure-communication-email/azure/communication/email/_configuration.py

@@ -8,48 +8,44 @@
 
 from typing import Any
 
-from azure.core.configuration import Configuration
 from azure.core.pipeline import policies
 
 from ._version import VERSION
 
 
-class AzureCommunicationEmailServiceConfiguration(Configuration):  # pylint: disable=too-many-instance-attributes
-    """Configuration for AzureCommunicationEmailService.
+class EmailClientConfiguration:  # pylint: disable=too-many-instance-attributes
+    """Configuration for EmailClient.
 
     Note that all parameters used to create this instance are saved as instance
     attributes.
 
     :param endpoint: The communication resource, for example
      https://my-resource.communication.azure.com. Required.
     :type endpoint: str
-    :keyword api_version: Api Version. Default value is "2024-07-01-preview". Note that overriding
-     this default value may result in unsupported behavior.
+    :keyword api_version: Api Version. Default value is "2025-09-01". Note that overriding this
+     default value may result in unsupported behavior.
     :paramtype api_version: str
     """
 
     def __init__(self, endpoint: str, **kwargs: Any) -> None:
-        super(AzureCommunicationEmailServiceConfiguration, self).__init__(**kwargs)
-        api_version = kwargs.pop("api_version", "2024-07-01-preview")  # type: str
+        api_version: str = kwargs.pop("api_version", "2025-09-01")
 
         if endpoint is None:
             raise ValueError("Parameter 'endpoint' must not be None.")
 
         self.endpoint = endpoint
         self.api_version = api_version
-        kwargs.setdefault("sdk_moniker", "azurecommunicationemailservice/{}".format(VERSION))
+        kwargs.setdefault("sdk_moniker", "emailclient/{}".format(VERSION))
+        self.polling_interval = kwargs.get("polling_interval", 30)
         self._configure(**kwargs)
 
-    def _configure(
-        self, **kwargs  # type: Any
-    ):
-        # type: (...) -> None
+    def _configure(self, **kwargs: Any) -> None:
         self.user_agent_policy = kwargs.get("user_agent_policy") or policies.UserAgentPolicy(**kwargs)
         self.headers_policy = kwargs.get("headers_policy") or policies.HeadersPolicy(**kwargs)
         self.proxy_policy = kwargs.get("proxy_policy") or policies.ProxyPolicy(**kwargs)
         self.logging_policy = kwargs.get("logging_policy") or policies.NetworkTraceLoggingPolicy(**kwargs)
         self.http_logging_policy = kwargs.get("http_logging_policy") or policies.HttpLoggingPolicy(**kwargs)
-        self.retry_policy = kwargs.get("retry_policy") or policies.RetryPolicy(**kwargs)
         self.custom_hook_policy = kwargs.get("custom_hook_policy") or policies.CustomHookPolicy(**kwargs)
         self.redirect_policy = kwargs.get("redirect_policy") or policies.RedirectPolicy(**kwargs)
+        self.retry_policy = kwargs.get("retry_policy") or policies.RetryPolicy(**kwargs)
         self.authentication_policy = kwargs.get("authentication_policy")