Skip to content

Commit e351fad

Browse files
Add maxNumberOfJobs + fix HMAC error (Azure#30084)
* Add maxNumberOfJobs + fix HMAC error * Fix tests + lint
1 parent 9e80439 commit e351fad

File tree

108 files changed

+26968
-190092
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

108 files changed

+26968
-190092
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@
4747
RouterJobStatus,
4848
JobAssignment,
4949
AcceptJobOfferResult,
50+
UnassignJobResult,
5051
JobPositionDetails,
5152
JobStateSelector,
5253
WorkerAssignment,
@@ -119,6 +120,7 @@
119120
'RouterJobStatus',
120121
'JobAssignment',
121122
'AcceptJobOfferResult',
123+
'UnassignJobResult',
122124
'JobPositionDetails',
123125
'JobStateSelector',
124126
'WorkerAssignment',

sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_generated/__init__.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,12 +10,14 @@
1010

1111
try:
1212
from ._patch import __all__ as _patch_all
13-
from ._patch import * # type: ignore # pylint: disable=unused-wildcard-import
13+
from ._patch import * # pylint: disable=unused-wildcard-import
1414
except ImportError:
1515
_patch_all = []
1616
from ._patch import patch_sdk as _patch_sdk
1717

18-
__all__ = ["AzureCommunicationJobRouterService"]
18+
__all__ = [
19+
"AzureCommunicationJobRouterService",
20+
]
1921
__all__.extend([p for p in _patch_all if p not in __all__])
2022

2123
_patch_sdk()

sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_generated/_client.py

Lines changed: 7 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -12,9 +12,9 @@
1212
from azure.core import PipelineClient
1313
from azure.core.rest import HttpRequest, HttpResponse
1414

15+
from . import models as _models
1516
from ._configuration import AzureCommunicationJobRouterServiceConfiguration
1617
from ._serialization import Deserializer, Serializer
17-
from .models import _models as models
1818
from .operations import JobRouterAdministrationOperations, JobRouterOperations
1919

2020

@@ -38,9 +38,10 @@ def __init__( # pylint: disable=missing-client-constructor-parameter-credential
3838
) -> None:
3939
_endpoint = "{endpoint}"
4040
self._config = AzureCommunicationJobRouterServiceConfiguration(endpoint=endpoint, **kwargs)
41-
self._client = PipelineClient(base_url=_endpoint, config=self._config, **kwargs)
41+
self._client: PipelineClient = PipelineClient(base_url=_endpoint, config=self._config, **kwargs)
4242

43-
client_models = {k: v for k, v in models.__dict__.items() if isinstance(v, type)}
43+
client_models = {k: v for k, v in _models._models.__dict__.items() if isinstance(v, type)}
44+
client_models.update({k: v for k, v in _models.__dict__.items() if isinstance(v, type)})
4445
self._serialize = Serializer(client_models)
4546
self._deserialize = Deserializer(client_models)
4647
self._serialize.client_side_validation = False
@@ -75,15 +76,12 @@ def send_request(self, request: HttpRequest, **kwargs: Any) -> HttpResponse:
7576
request_copy.url = self._client.format_url(request_copy.url, **path_format_arguments)
7677
return self._client.send_request(request_copy, **kwargs)
7778

78-
def close(self):
79-
# type: () -> None
79+
def close(self) -> None:
8080
self._client.close()
8181

82-
def __enter__(self):
83-
# type: () -> AzureCommunicationJobRouterService
82+
def __enter__(self) -> "AzureCommunicationJobRouterService":
8483
self._client.__enter__()
8584
return self
8685

87-
def __exit__(self, *exc_details):
88-
# type: (Any) -> None
86+
def __exit__(self, *exc_details: Any) -> None:
8987
self._client.__exit__(*exc_details)

sdk/communication/azure-communication-jobrouter/azure/communication/jobrouter/_generated/_configuration.py

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ class AzureCommunicationJobRouterServiceConfiguration(Configuration): # pylint:
2929

3030
def __init__(self, endpoint: str, **kwargs: Any) -> None:
3131
super(AzureCommunicationJobRouterServiceConfiguration, self).__init__(**kwargs)
32-
api_version = kwargs.pop("api_version", "2022-07-18-preview") # type: str
32+
api_version: str = kwargs.pop("api_version", "2022-07-18-preview")
3333

3434
if endpoint is None:
3535
raise ValueError("Parameter 'endpoint' must not be None.")
@@ -39,10 +39,7 @@ def __init__(self, endpoint: str, **kwargs: Any) -> None:
3939
kwargs.setdefault("sdk_moniker", "communication-jobrouter/{}".format(VERSION))
4040
self._configure(**kwargs)
4141

42-
def _configure(
43-
self, **kwargs # type: Any
44-
):
45-
# type: (...) -> None
42+
def _configure(self, **kwargs: Any) -> None:
4643
self.user_agent_policy = kwargs.get("user_agent_policy") or policies.UserAgentPolicy(**kwargs)
4744
self.headers_policy = kwargs.get("headers_policy") or policies.HeadersPolicy(**kwargs)
4845
self.proxy_policy = kwargs.get("proxy_policy") or policies.ProxyPolicy(**kwargs)

0 commit comments

Comments
 (0)