Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 4 additions & 0 deletions sdk/cognitivelanguage/azure-ai-textanalytics/CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,5 +1,9 @@
# Release History

## 6.0.0b3 (2026-06-08)

skip changelog generation for data-plane package and please add changelog manually.

## 6.0.0b2 (2025-11-06)

This version of the client library defaults to the service API version `2025-11-15-preview`.
Expand Down
Original file line number Diff line number Diff line change
@@ -1,3 +1,10 @@
{
"apiVersion": "2025-11-15-preview"
"apiVersion": "2026-05-15-preview",
"apiVersions": {
"Language.Text": "2026-05-15-preview"
},
"commit": "04869e1f580276ee3e7e51b74dd7e23df50902b8",
"repository_url": "https://github.com/Azure/azure-rest-api-specs",
"typespec_src": "specification/cognitiveservices/data-plane/LanguageAnalyzeText",
"emitterVersion": "0.63.0"
}
Original file line number Diff line number Diff line change
Expand Up @@ -200,5 +200,6 @@
"azure.ai.textanalytics.aio.TextAnalysisClient.begin_analyze_text_job": "Language.Text.analyzeTextSubmitJob",
"azure.ai.textanalytics.TextAnalysisClient.begin_cancel_job": "Language.Text.analyzeTextCancelJob",
"azure.ai.textanalytics.aio.TextAnalysisClient.begin_cancel_job": "Language.Text.analyzeTextCancelJob"
}
},
"CrossLanguageVersion": "16251edc0967"
}
Original file line number Diff line number Diff line change
Expand Up @@ -8,8 +8,8 @@
# --------------------------------------------------------------------------

from copy import deepcopy
import sys
from typing import Any, TYPE_CHECKING, Union
from typing_extensions import Self

from azure.core import PipelineClient
from azure.core.credentials import AzureKeyCredential
Expand All @@ -20,6 +20,11 @@
from ._operations import _TextAnalysisClientOperationsMixin
from ._utils.serialization import Deserializer, Serializer

if sys.version_info >= (3, 11):
from typing import Self
else:
from typing_extensions import Self # type: ignore

if TYPE_CHECKING:
from azure.core.credentials import TokenCredential

Expand All @@ -39,8 +44,9 @@ class TextAnalysisClient(_TextAnalysisClientOperationsMixin):
credential type or a token credential type. Required.
:type credential: ~azure.core.credentials.AzureKeyCredential or
~azure.core.credentials.TokenCredential
:keyword api_version: The API version to use for this operation. Default value is
"2025-11-15-preview". Note that overriding this default value may result in unsupported
:keyword api_version: The API version to use for this operation. Known values are
"2026-05-15-preview" and None. Default value is None. If not set, the operation's default API
version will be used. 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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,14 +30,15 @@ class TextAnalysisClientConfiguration: # pylint: disable=too-many-instance-attr
credential type or a token credential type. Required.
:type credential: ~azure.core.credentials.AzureKeyCredential or
~azure.core.credentials.TokenCredential
:keyword api_version: The API version to use for this operation. Default value is
"2025-11-15-preview". Note that overriding this default value may result in unsupported
:keyword api_version: The API version to use for this operation. Known values are
"2026-05-15-preview" and None. Default value is None. If not set, the operation's default API
version will be used. Note that overriding this default value may result in unsupported
behavior.
:paramtype api_version: str
"""

def __init__(self, endpoint: str, credential: Union[AzureKeyCredential, "TokenCredential"], **kwargs: Any) -> None:
api_version: str = kwargs.pop("api_version", "2025-11-15-preview")
api_version: str = kwargs.pop("api_version", "2026-05-15-preview")

if endpoint is None:
raise ValueError("Parameter 'endpoint' must not be None.")
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@ def build_text_analysis_analyze_text_request(*, show_stats: Optional[bool] = Non
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})

content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None))
api_version: str = kwargs.pop("api_version", _params.pop("api-version", "2025-11-15-preview"))
api_version: str = kwargs.pop("api_version", _params.pop("api-version", "2026-05-15-preview"))
accept = _headers.pop("Accept", "application/json")

# Construct URL
Expand Down Expand Up @@ -78,7 +78,7 @@ def build_text_analysis_get_job_status_request( # pylint: disable=name-too-long
_headers = case_insensitive_dict(kwargs.pop("headers", {}) or {})
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})

api_version: str = kwargs.pop("api_version", _params.pop("api-version", "2025-11-15-preview"))
api_version: str = kwargs.pop("api_version", _params.pop("api-version", "2026-05-15-preview"))
accept = _headers.pop("Accept", "application/json")

# Construct URL
Expand Down Expand Up @@ -109,7 +109,7 @@ def build_text_analysis_analyze_text_job_request(**kwargs: Any) -> HttpRequest:
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})

content_type: Optional[str] = kwargs.pop("content_type", _headers.pop("Content-Type", None))
api_version: str = kwargs.pop("api_version", _params.pop("api-version", "2025-11-15-preview"))
api_version: str = kwargs.pop("api_version", _params.pop("api-version", "2026-05-15-preview"))
# Construct URL
_url = "/analyze-text/jobs"

Expand All @@ -126,7 +126,7 @@ def build_text_analysis_analyze_text_job_request(**kwargs: Any) -> HttpRequest:
def build_text_analysis_cancel_job_request(job_id: str, **kwargs: Any) -> HttpRequest:
_params = case_insensitive_dict(kwargs.pop("params", {}) or {})

api_version: str = kwargs.pop("api_version", _params.pop("api-version", "2025-11-15-preview"))
api_version: str = kwargs.pop("api_version", _params.pop("api-version", "2026-05-15-preview"))
# Construct URL
_url = "/analyze-text/jobs/{jobId}:cancel"
path_format_arguments = {
Expand Down Expand Up @@ -266,6 +266,7 @@ def analyze_text(
}
_request.url = self._client.format_url(_request.url, **path_format_arguments)

_decompress = kwargs.pop("decompress", True)
_stream = kwargs.pop("stream", False)
pipeline_response: PipelineResponse = self._client._pipeline.run( # pylint: disable=protected-access
_request, stream=_stream, **kwargs
Expand All @@ -287,7 +288,7 @@ def analyze_text(
raise HttpResponseError(response=response, model=error)

if _stream:
deserialized = response.iter_bytes()
deserialized = response.iter_bytes() if _decompress else response.iter_raw()
else:
deserialized = _deserialize(_models.AnalyzeTextResult, response.json())

Expand Down Expand Up @@ -354,6 +355,7 @@ def get_job_status(
}
_request.url = self._client.format_url(_request.url, **path_format_arguments)

_decompress = kwargs.pop("decompress", True)
_stream = kwargs.pop("stream", False)
pipeline_response: PipelineResponse = self._client._pipeline.run( # pylint: disable=protected-access
_request, stream=_stream, **kwargs
Expand All @@ -375,7 +377,7 @@ def get_job_status(
raise HttpResponseError(response=response, model=error)

if _stream:
deserialized = response.iter_bytes()
deserialized = response.iter_bytes() if _decompress else response.iter_raw()
else:
deserialized = _deserialize(_models.AnalyzeTextOperationState, response.json())

Expand Down Expand Up @@ -441,6 +443,7 @@ def _analyze_text_job_initial(
}
_request.url = self._client.format_url(_request.url, **path_format_arguments)

_decompress = kwargs.pop("decompress", True)
_stream = True
pipeline_response: PipelineResponse = self._client._pipeline.run( # pylint: disable=protected-access
_request, stream=_stream, **kwargs
Expand All @@ -463,7 +466,7 @@ def _analyze_text_job_initial(
response_headers = {}
response_headers["Operation-Location"] = self._deserialize("str", response.headers.get("Operation-Location"))

deserialized = response.iter_bytes()
deserialized = response.iter_bytes() if _decompress else response.iter_raw()

if cls:
return cls(pipeline_response, deserialized, response_headers) # type: ignore
Expand Down Expand Up @@ -647,6 +650,7 @@ def _cancel_job_initial(self, job_id: str, **kwargs: Any) -> Iterator[bytes]:
}
_request.url = self._client.format_url(_request.url, **path_format_arguments)

_decompress = kwargs.pop("decompress", True)
_stream = True
pipeline_response: PipelineResponse = self._client._pipeline.run( # pylint: disable=protected-access
_request, stream=_stream, **kwargs
Expand All @@ -669,7 +673,7 @@ def _cancel_job_initial(self, job_id: str, **kwargs: Any) -> Iterator[bytes]:
response_headers = {}
response_headers["Operation-Location"] = self._deserialize("str", response.headers.get("Operation-Location"))

deserialized = response.iter_bytes()
deserialized = response.iter_bytes() if _decompress else response.iter_raw()

if cls:
return cls(pipeline_response, deserialized, response_headers) # type: ignore
Expand Down
Loading
Loading