From 9488bddf35813be2727b9e1784f811d97629b21e Mon Sep 17 00:00:00 2001 From: SDKAuto Date: Tue, 21 Nov 2023 18:53:26 +0000 Subject: [PATCH] CodeGen from PR 26779 in Azure/azure-rest-api-specs Merge b781e47e4f376f606156f9705ad6e87a06acacc5 into 408ec578623f6e4856a7a188b5eb28cfa08528c4 --- .../azure-communication-jobrouter/_meta.json | 6 ++++++ .../azure/communication/jobrouter/__init__.py | 4 ++-- .../azure/communication/jobrouter/_client.py | 17 +++++++++-------- .../communication/jobrouter/_configuration.py | 19 +++++++++++++++++-- .../jobrouter/_operations/__init__.py | 4 ++-- .../jobrouter/_operations/_operations.py | 14 +++++++------- .../communication/jobrouter/aio/__init__.py | 4 ++-- .../communication/jobrouter/aio/_client.py | 17 +++++++++-------- .../jobrouter/aio/_configuration.py | 19 +++++++++++++++++-- .../jobrouter/aio/_operations/__init__.py | 4 ++-- .../jobrouter/aio/_operations/_operations.py | 14 +++++++------- .../communication/jobrouter/models/_models.py | 3 ++- .../tsp-location.yaml | 4 ++-- 13 files changed, 84 insertions(+), 45 deletions(-) create mode 100644 sdk/communication/azure-communication-jobrouter/_meta.json diff --git a/sdk/communication/azure-communication-jobrouter/_meta.json b/sdk/communication/azure-communication-jobrouter/_meta.json new file mode 100644 index 000000000000..6c5a1881b493 --- /dev/null +++ b/sdk/communication/azure-communication-jobrouter/_meta.json @@ -0,0 +1,6 @@ +{ + "commit": "91d0dc2cee749326936b7c62d7eca645abf5ae53", + "repository_url": "https://github.com/Azure/azure-rest-api-specs", + "typespec_src": "specification/communication/Communication.JobRouter", + "@azure-tools/typespec-python": "0.15.14" +} \ No newline at end of file diff --git a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/__init__.py b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/__init__.py index ba2b07fc1b38..30a55b8c5a1c 100644 --- a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/__init__.py +++ b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/__init__.py @@ -6,8 +6,8 @@ # Changes may cause incorrect behavior and will be lost if the code is regenerated. # -------------------------------------------------------------------------- -from ._patch import JobRouterAdministrationClient -from ._patch import JobRouterClient +from ._client import JobRouterAdministrationClient +from ._client import JobRouterClient from ._version import VERSION __version__ = VERSION diff --git a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_client.py b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_client.py index ad6f17f9f863..175bc0ffa27b 100644 --- a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_client.py +++ b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_client.py @@ -10,6 +10,7 @@ from typing import Any from azure.core import PipelineClient +from azure.core.credentials import AzureKeyCredential from azure.core.pipeline import policies from azure.core.rest import HttpRequest, HttpResponse @@ -25,16 +26,16 @@ class JobRouterAdministrationClient( :param endpoint: Uri of your Communication resource. Required. :type endpoint: str + :param credential: Credential needed for the client to connect to Azure. Required. + :type credential: ~azure.core.credentials.AzureKeyCredential :keyword api_version: The API version to use for this operation. Default value is "2023-11-01". Note that overriding this default value may result in unsupported behavior. :paramtype api_version: str """ - def __init__( # pylint: disable=missing-client-constructor-parameter-credential - self, endpoint: str, **kwargs: Any - ) -> None: + def __init__(self, endpoint: str, credential: AzureKeyCredential, **kwargs: Any) -> None: _endpoint = "{endpoint}" - self._config = JobRouterAdministrationClientConfiguration(endpoint=endpoint, **kwargs) + self._config = JobRouterAdministrationClientConfiguration(endpoint=endpoint, credential=credential, **kwargs) _policies = kwargs.pop("policies", None) if _policies is None: _policies = [ @@ -100,16 +101,16 @@ class JobRouterClient(JobRouterClientOperationsMixin): # pylint: disable=client :param endpoint: Uri of your Communication resource. Required. :type endpoint: str + :param credential: Credential needed for the client to connect to Azure. Required. + :type credential: ~azure.core.credentials.AzureKeyCredential :keyword api_version: The API version to use for this operation. Default value is "2023-11-01". Note that overriding this default value may result in unsupported behavior. :paramtype api_version: str """ - def __init__( # pylint: disable=missing-client-constructor-parameter-credential - self, endpoint: str, **kwargs: Any - ) -> None: + def __init__(self, endpoint: str, credential: AzureKeyCredential, **kwargs: Any) -> None: _endpoint = "{endpoint}" - self._config = JobRouterClientConfiguration(endpoint=endpoint, **kwargs) + self._config = JobRouterClientConfiguration(endpoint=endpoint, credential=credential, **kwargs) _policies = kwargs.pop("policies", None) if _policies is None: _policies = [ diff --git a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_configuration.py b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_configuration.py index bb7bf7ce4aa2..c2ffeff6a1e5 100644 --- a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_configuration.py +++ b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_configuration.py @@ -8,6 +8,7 @@ from typing import Any +from azure.core.credentials import AzureKeyCredential from azure.core.pipeline import policies from ._version import VERSION @@ -21,18 +22,23 @@ class JobRouterAdministrationClientConfiguration: # pylint: disable=too-many-in :param endpoint: Uri of your Communication resource. Required. :type endpoint: str + :param credential: Credential needed for the client to connect to Azure. Required. + :type credential: ~azure.core.credentials.AzureKeyCredential :keyword api_version: The API version to use for this operation. Default value is "2023-11-01". Note that overriding this default value may result in unsupported behavior. :paramtype api_version: str """ - def __init__(self, endpoint: str, **kwargs: Any) -> None: + def __init__(self, endpoint: str, credential: AzureKeyCredential, **kwargs: Any) -> None: api_version: str = kwargs.pop("api_version", "2023-11-01") if endpoint is None: raise ValueError("Parameter 'endpoint' must not be None.") + if credential is None: + raise ValueError("Parameter 'credential' must not be None.") self.endpoint = endpoint + self.credential = credential self.api_version = api_version kwargs.setdefault("sdk_moniker", "communication-jobrouter/{}".format(VERSION)) self.polling_interval = kwargs.get("polling_interval", 30) @@ -48,6 +54,8 @@ def _configure(self, **kwargs: Any) -> None: 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") + if self.credential and not self.authentication_policy: + self.authentication_policy = policies.AzureKeyCredentialPolicy(self.credential, "api-key", **kwargs) class JobRouterClientConfiguration: # pylint: disable=too-many-instance-attributes,name-too-long @@ -58,18 +66,23 @@ class JobRouterClientConfiguration: # pylint: disable=too-many-instance-attribu :param endpoint: Uri of your Communication resource. Required. :type endpoint: str + :param credential: Credential needed for the client to connect to Azure. Required. + :type credential: ~azure.core.credentials.AzureKeyCredential :keyword api_version: The API version to use for this operation. Default value is "2023-11-01". Note that overriding this default value may result in unsupported behavior. :paramtype api_version: str """ - def __init__(self, endpoint: str, **kwargs: Any) -> None: + def __init__(self, endpoint: str, credential: AzureKeyCredential, **kwargs: Any) -> None: api_version: str = kwargs.pop("api_version", "2023-11-01") if endpoint is None: raise ValueError("Parameter 'endpoint' must not be None.") + if credential is None: + raise ValueError("Parameter 'credential' must not be None.") self.endpoint = endpoint + self.credential = credential self.api_version = api_version kwargs.setdefault("sdk_moniker", "communication-jobrouter/{}".format(VERSION)) self.polling_interval = kwargs.get("polling_interval", 30) @@ -85,3 +98,5 @@ def _configure(self, **kwargs: Any) -> None: 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") + if self.credential and not self.authentication_policy: + self.authentication_policy = policies.AzureKeyCredentialPolicy(self.credential, "api-key", **kwargs) diff --git a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_operations/__init__.py b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_operations/__init__.py index 06eb1614ceb7..716a8d30dd24 100644 --- a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_operations/__init__.py +++ b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_operations/__init__.py @@ -6,8 +6,8 @@ # Changes may cause incorrect behavior and will be lost if the code is regenerated. # -------------------------------------------------------------------------- -from ._patch import JobRouterAdministrationClientOperationsMixin -from ._patch import JobRouterClientOperationsMixin +from ._operations import JobRouterAdministrationClientOperationsMixin +from ._operations import JobRouterClientOperationsMixin from ._patch import __all__ as _patch_all from ._patch import * # pylint: disable=unused-wildcard-import diff --git a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_operations/_operations.py b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_operations/_operations.py index ffd66a0b45d9..520bb805b26b 100644 --- a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_operations/_operations.py +++ b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_operations/_operations.py @@ -10,7 +10,7 @@ from io import IOBase import json import sys -from typing import Any, Callable, Dict, IO, List, Optional, TypeVar, Union, overload +from typing import Any, Callable, Dict, IO, Iterable, List, Optional, TypeVar, Union, overload import urllib.parse from azure.core import MatchConditions @@ -1286,7 +1286,7 @@ def get_distribution_policy(self, distribution_policy_id: str, **kwargs: Any) -> return deserialized # type: ignore @distributed_trace - def list_distribution_policies(self, **kwargs: Any) -> ItemPaged["_models.DistributionPolicy"]: + def list_distribution_policies(self, **kwargs: Any) -> Iterable["_models.DistributionPolicy"]: """Retrieves existing distribution policies. Retrieves existing distribution policies. @@ -1723,7 +1723,7 @@ def get_classification_policy(self, classification_policy_id: str, **kwargs: Any return deserialized # type: ignore @distributed_trace - def list_classification_policies(self, **kwargs: Any) -> ItemPaged["_models.ClassificationPolicy"]: + def list_classification_policies(self, **kwargs: Any) -> Iterable["_models.ClassificationPolicy"]: """Retrieves existing classification policies. Retrieves existing classification policies. @@ -2161,7 +2161,7 @@ def get_exception_policy(self, exception_policy_id: str, **kwargs: Any) -> _mode return deserialized # type: ignore @distributed_trace - def list_exception_policies(self, **kwargs: Any) -> ItemPaged["_models.ExceptionPolicy"]: + def list_exception_policies(self, **kwargs: Any) -> Iterable["_models.ExceptionPolicy"]: """Retrieves existing exception policies. Retrieves existing exception policies. @@ -2598,7 +2598,7 @@ def get_queue(self, queue_id: str, **kwargs: Any) -> _models.RouterQueue: return deserialized # type: ignore @distributed_trace - def list_queues(self, **kwargs: Any) -> ItemPaged["_models.RouterQueue"]: + def list_queues(self, **kwargs: Any) -> Iterable["_models.RouterQueue"]: """Retrieves existing queues. Retrieves existing queues. @@ -3568,7 +3568,7 @@ def list_jobs( scheduled_before: Optional[datetime.datetime] = None, scheduled_after: Optional[datetime.datetime] = None, **kwargs: Any - ) -> ItemPaged["_models.RouterJob"]: + ) -> Iterable["_models.RouterJob"]: """Retrieves list of jobs based on filter parameters. Retrieves list of jobs based on filter parameters. @@ -4532,7 +4532,7 @@ def list_workers( queue_id: Optional[str] = None, has_capacity: Optional[bool] = None, **kwargs: Any - ) -> ItemPaged["_models.RouterWorker"]: + ) -> Iterable["_models.RouterWorker"]: """Retrieves existing workers. Retrieves existing workers. diff --git a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/__init__.py b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/__init__.py index 2cad3c9bd6b0..4a879c5b9463 100644 --- a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/__init__.py +++ b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/__init__.py @@ -6,8 +6,8 @@ # Changes may cause incorrect behavior and will be lost if the code is regenerated. # -------------------------------------------------------------------------- -from ._patch import JobRouterAdministrationClient -from ._patch import JobRouterClient +from ._client import JobRouterAdministrationClient +from ._client import JobRouterClient try: from ._patch import __all__ as _patch_all diff --git a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_client.py b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_client.py index 9d9a25d2b0ce..4cf6894d8201 100644 --- a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_client.py +++ b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_client.py @@ -10,6 +10,7 @@ from typing import Any, Awaitable from azure.core import AsyncPipelineClient +from azure.core.credentials import AzureKeyCredential from azure.core.pipeline import policies from azure.core.rest import AsyncHttpResponse, HttpRequest @@ -25,16 +26,16 @@ class JobRouterAdministrationClient( :param endpoint: Uri of your Communication resource. Required. :type endpoint: str + :param credential: Credential needed for the client to connect to Azure. Required. + :type credential: ~azure.core.credentials.AzureKeyCredential :keyword api_version: The API version to use for this operation. Default value is "2023-11-01". Note that overriding this default value may result in unsupported behavior. :paramtype api_version: str """ - def __init__( # pylint: disable=missing-client-constructor-parameter-credential - self, endpoint: str, **kwargs: Any - ) -> None: + def __init__(self, endpoint: str, credential: AzureKeyCredential, **kwargs: Any) -> None: _endpoint = "{endpoint}" - self._config = JobRouterAdministrationClientConfiguration(endpoint=endpoint, **kwargs) + self._config = JobRouterAdministrationClientConfiguration(endpoint=endpoint, credential=credential, **kwargs) _policies = kwargs.pop("policies", None) if _policies is None: _policies = [ @@ -102,16 +103,16 @@ class JobRouterClient(JobRouterClientOperationsMixin): # pylint: disable=client :param endpoint: Uri of your Communication resource. Required. :type endpoint: str + :param credential: Credential needed for the client to connect to Azure. Required. + :type credential: ~azure.core.credentials.AzureKeyCredential :keyword api_version: The API version to use for this operation. Default value is "2023-11-01". Note that overriding this default value may result in unsupported behavior. :paramtype api_version: str """ - def __init__( # pylint: disable=missing-client-constructor-parameter-credential - self, endpoint: str, **kwargs: Any - ) -> None: + def __init__(self, endpoint: str, credential: AzureKeyCredential, **kwargs: Any) -> None: _endpoint = "{endpoint}" - self._config = JobRouterClientConfiguration(endpoint=endpoint, **kwargs) + self._config = JobRouterClientConfiguration(endpoint=endpoint, credential=credential, **kwargs) _policies = kwargs.pop("policies", None) if _policies is None: _policies = [ diff --git a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_configuration.py b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_configuration.py index 30c36dad559e..604408873b58 100644 --- a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_configuration.py +++ b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_configuration.py @@ -8,6 +8,7 @@ from typing import Any +from azure.core.credentials import AzureKeyCredential from azure.core.pipeline import policies from .._version import VERSION @@ -21,18 +22,23 @@ class JobRouterAdministrationClientConfiguration: # pylint: disable=too-many-in :param endpoint: Uri of your Communication resource. Required. :type endpoint: str + :param credential: Credential needed for the client to connect to Azure. Required. + :type credential: ~azure.core.credentials.AzureKeyCredential :keyword api_version: The API version to use for this operation. Default value is "2023-11-01". Note that overriding this default value may result in unsupported behavior. :paramtype api_version: str """ - def __init__(self, endpoint: str, **kwargs: Any) -> None: + def __init__(self, endpoint: str, credential: AzureKeyCredential, **kwargs: Any) -> None: api_version: str = kwargs.pop("api_version", "2023-11-01") if endpoint is None: raise ValueError("Parameter 'endpoint' must not be None.") + if credential is None: + raise ValueError("Parameter 'credential' must not be None.") self.endpoint = endpoint + self.credential = credential self.api_version = api_version kwargs.setdefault("sdk_moniker", "communication-jobrouter/{}".format(VERSION)) self.polling_interval = kwargs.get("polling_interval", 30) @@ -48,6 +54,8 @@ def _configure(self, **kwargs: Any) -> None: self.redirect_policy = kwargs.get("redirect_policy") or policies.AsyncRedirectPolicy(**kwargs) self.retry_policy = kwargs.get("retry_policy") or policies.AsyncRetryPolicy(**kwargs) self.authentication_policy = kwargs.get("authentication_policy") + if self.credential and not self.authentication_policy: + self.authentication_policy = policies.AzureKeyCredentialPolicy(self.credential, "api-key", **kwargs) class JobRouterClientConfiguration: # pylint: disable=too-many-instance-attributes,name-too-long @@ -58,18 +66,23 @@ class JobRouterClientConfiguration: # pylint: disable=too-many-instance-attribu :param endpoint: Uri of your Communication resource. Required. :type endpoint: str + :param credential: Credential needed for the client to connect to Azure. Required. + :type credential: ~azure.core.credentials.AzureKeyCredential :keyword api_version: The API version to use for this operation. Default value is "2023-11-01". Note that overriding this default value may result in unsupported behavior. :paramtype api_version: str """ - def __init__(self, endpoint: str, **kwargs: Any) -> None: + def __init__(self, endpoint: str, credential: AzureKeyCredential, **kwargs: Any) -> None: api_version: str = kwargs.pop("api_version", "2023-11-01") if endpoint is None: raise ValueError("Parameter 'endpoint' must not be None.") + if credential is None: + raise ValueError("Parameter 'credential' must not be None.") self.endpoint = endpoint + self.credential = credential self.api_version = api_version kwargs.setdefault("sdk_moniker", "communication-jobrouter/{}".format(VERSION)) self.polling_interval = kwargs.get("polling_interval", 30) @@ -85,3 +98,5 @@ def _configure(self, **kwargs: Any) -> None: self.redirect_policy = kwargs.get("redirect_policy") or policies.AsyncRedirectPolicy(**kwargs) self.retry_policy = kwargs.get("retry_policy") or policies.AsyncRetryPolicy(**kwargs) self.authentication_policy = kwargs.get("authentication_policy") + if self.credential and not self.authentication_policy: + self.authentication_policy = policies.AzureKeyCredentialPolicy(self.credential, "api-key", **kwargs) diff --git a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_operations/__init__.py b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_operations/__init__.py index 06eb1614ceb7..716a8d30dd24 100644 --- a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_operations/__init__.py +++ b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_operations/__init__.py @@ -6,8 +6,8 @@ # Changes may cause incorrect behavior and will be lost if the code is regenerated. # -------------------------------------------------------------------------- -from ._patch import JobRouterAdministrationClientOperationsMixin -from ._patch import JobRouterClientOperationsMixin +from ._operations import JobRouterAdministrationClientOperationsMixin +from ._operations import JobRouterClientOperationsMixin from ._patch import __all__ as _patch_all from ._patch import * # pylint: disable=unused-wildcard-import diff --git a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_operations/_operations.py b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_operations/_operations.py index d0741ef97a49..ad80c40fbfd6 100644 --- a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_operations/_operations.py +++ b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/aio/_operations/_operations.py @@ -10,7 +10,7 @@ from io import IOBase import json import sys -from typing import Any, Callable, Dict, IO, List, Optional, TypeVar, Union, overload +from typing import Any, AsyncIterable, Callable, Dict, IO, List, Optional, TypeVar, Union, overload import urllib.parse from azure.core import MatchConditions @@ -377,7 +377,7 @@ async def get_distribution_policy(self, distribution_policy_id: str, **kwargs: A return deserialized # type: ignore @distributed_trace - def list_distribution_policies(self, **kwargs: Any) -> AsyncItemPaged["_models.DistributionPolicy"]: + def list_distribution_policies(self, **kwargs: Any) -> AsyncIterable["_models.DistributionPolicy"]: """Retrieves existing distribution policies. Retrieves existing distribution policies. @@ -817,7 +817,7 @@ async def get_classification_policy( return deserialized # type: ignore @distributed_trace - def list_classification_policies(self, **kwargs: Any) -> AsyncItemPaged["_models.ClassificationPolicy"]: + def list_classification_policies(self, **kwargs: Any) -> AsyncIterable["_models.ClassificationPolicy"]: """Retrieves existing classification policies. Retrieves existing classification policies. @@ -1255,7 +1255,7 @@ async def get_exception_policy(self, exception_policy_id: str, **kwargs: Any) -> return deserialized # type: ignore @distributed_trace - def list_exception_policies(self, **kwargs: Any) -> AsyncItemPaged["_models.ExceptionPolicy"]: + def list_exception_policies(self, **kwargs: Any) -> AsyncIterable["_models.ExceptionPolicy"]: """Retrieves existing exception policies. Retrieves existing exception policies. @@ -1693,7 +1693,7 @@ async def get_queue(self, queue_id: str, **kwargs: Any) -> _models.RouterQueue: return deserialized # type: ignore @distributed_trace - def list_queues(self, **kwargs: Any) -> AsyncItemPaged["_models.RouterQueue"]: + def list_queues(self, **kwargs: Any) -> AsyncIterable["_models.RouterQueue"]: """Retrieves existing queues. Retrieves existing queues. @@ -2666,7 +2666,7 @@ def list_jobs( scheduled_before: Optional[datetime.datetime] = None, scheduled_after: Optional[datetime.datetime] = None, **kwargs: Any - ) -> AsyncItemPaged["_models.RouterJob"]: + ) -> AsyncIterable["_models.RouterJob"]: """Retrieves list of jobs based on filter parameters. Retrieves list of jobs based on filter parameters. @@ -3633,7 +3633,7 @@ def list_workers( queue_id: Optional[str] = None, has_capacity: Optional[bool] = None, **kwargs: Any - ) -> AsyncItemPaged["_models.RouterWorker"]: + ) -> AsyncIterable["_models.RouterWorker"]: """Retrieves existing workers. Retrieves existing workers. diff --git a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/models/_models.py b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/models/_models.py index 68689b307e12..062d4194cdb9 100644 --- a/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/models/_models.py +++ b/sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/models/_models.py @@ -1,5 +1,5 @@ # coding=utf-8 -# pylint: disable=too-many-lines,anomalous-backslash-in-string,name-too-long +# pylint: disable=too-many-lines # -------------------------------------------------------------------------- # Copyright (c) Microsoft Corporation. All rights reserved. # Licensed under the MIT License. See License.txt in the project root for license information. @@ -98,6 +98,7 @@ class DistributionMode(_model_base.Model): values are: "bestWorker", "longestIdle", and "roundRobin". :vartype kind: str or ~azure.communication.jobrouter.models.DistributionModeKind """ + __mapping__: Dict[str, _model_base.Model] = {} min_concurrent_offers: Optional[int] = rest_field(name="minConcurrentOffers") """Governs the minimum desired number of active concurrent offers a job can have.""" diff --git a/sdk/communication/azure-communication-jobrouter/tsp-location.yaml b/sdk/communication/azure-communication-jobrouter/tsp-location.yaml index 142c21483fcd..3d397cb37431 100644 --- a/sdk/communication/azure-communication-jobrouter/tsp-location.yaml +++ b/sdk/communication/azure-communication-jobrouter/tsp-location.yaml @@ -1,5 +1,5 @@ +commit: 91d0dc2cee749326936b7c62d7eca645abf5ae53 +directory: specification/communication/Communication.JobRouter repo: Azure/azure-rest-api-specs additionalDirectories: [] -directory: specification/communication/Communication.JobRouter -commit: 2d044b8a317aff46d45080f5a797ac376955f648