CodeGen from PR 18305 in Azure/azure-rest-api-specs

Merge 61c845101521c651ed892fb7e33aea71ee0c0db5 into 4bd83868c6ae7f731874b6673f400ca97914ee97

Author: SDKAuto

sdk/streamanalytics/azure-mgmt-streamanalytics/_meta.json

@@ -4,7 +4,7 @@
     "@autorest/[email protected]",
     "@autorest/[email protected]"
   ],
-  "commit": "0ca8399b0e4fb4ae4608ffd0a6c056213664dacd",
+  "commit": "80adcdcee4ebf4c120333e0f82b25ac84a940267",
   "repository_url": "https://github.com/Azure/azure-rest-api-specs",
   "autorest_command": "autorest specification/streamanalytics/resource-manager/readme.md --multiapi --python --python-mode=update --python-sdks-folder=/home/vsts/work/1/s/azure-sdk-for-python/sdk --python3-only --track2 --use=@autorest/[email protected] --use=@autorest/[email protected] --version=3.7.2",
   "readme": "specification/streamanalytics/resource-manager/readme.md"

sdk/streamanalytics/azure-mgmt-streamanalytics/azure/mgmt/streamanalytics/_stream_analytics_management_client.py

@@ -25,25 +25,23 @@ class StreamAnalyticsManagementClient:
     """Stream Analytics Client.
 
     :ivar operations: Operations operations
-    :vartype operations: stream_analytics_management_client.operations.Operations
+    :vartype operations: azure.mgmt.streamanalytics.operations.Operations
     :ivar streaming_jobs: StreamingJobsOperations operations
-    :vartype streaming_jobs: stream_analytics_management_client.operations.StreamingJobsOperations
+    :vartype streaming_jobs: azure.mgmt.streamanalytics.operations.StreamingJobsOperations
     :ivar inputs: InputsOperations operations
-    :vartype inputs: stream_analytics_management_client.operations.InputsOperations
+    :vartype inputs: azure.mgmt.streamanalytics.operations.InputsOperations
     :ivar outputs: OutputsOperations operations
-    :vartype outputs: stream_analytics_management_client.operations.OutputsOperations
+    :vartype outputs: azure.mgmt.streamanalytics.operations.OutputsOperations
     :ivar transformations: TransformationsOperations operations
-    :vartype transformations:
-     stream_analytics_management_client.operations.TransformationsOperations
+    :vartype transformations: azure.mgmt.streamanalytics.operations.TransformationsOperations
     :ivar functions: FunctionsOperations operations
-    :vartype functions: stream_analytics_management_client.operations.FunctionsOperations
+    :vartype functions: azure.mgmt.streamanalytics.operations.FunctionsOperations
     :ivar subscriptions: SubscriptionsOperations operations
-    :vartype subscriptions: stream_analytics_management_client.operations.SubscriptionsOperations
+    :vartype subscriptions: azure.mgmt.streamanalytics.operations.SubscriptionsOperations
     :ivar clusters: ClustersOperations operations
-    :vartype clusters: stream_analytics_management_client.operations.ClustersOperations
+    :vartype clusters: azure.mgmt.streamanalytics.operations.ClustersOperations
     :ivar private_endpoints: PrivateEndpointsOperations operations
-    :vartype private_endpoints:
-     stream_analytics_management_client.operations.PrivateEndpointsOperations
+    :vartype private_endpoints: azure.mgmt.streamanalytics.operations.PrivateEndpointsOperations
     :param credential: Credential needed for the client to connect to Azure.
     :type credential: ~azure.core.credentials.TokenCredential
     :param subscription_id: The ID of the target subscription.

sdk/streamanalytics/azure-mgmt-streamanalytics/azure/mgmt/streamanalytics/_version.py

@@ -6,4 +6,4 @@
 # Changes may cause incorrect behavior and will be lost if the code is regenerated.
 # --------------------------------------------------------------------------
 
-VERSION = "1.0.0"
+VERSION = "1.0.0b1"

sdk/streamanalytics/azure-mgmt-streamanalytics/azure/mgmt/streamanalytics/aio/_stream_analytics_management_client.py

@@ -25,27 +25,24 @@ class StreamAnalyticsManagementClient:
     """Stream Analytics Client.
 
     :ivar operations: Operations operations
-    :vartype operations: stream_analytics_management_client.aio.operations.Operations
+    :vartype operations: azure.mgmt.streamanalytics.aio.operations.Operations
     :ivar streaming_jobs: StreamingJobsOperations operations
-    :vartype streaming_jobs:
-     stream_analytics_management_client.aio.operations.StreamingJobsOperations
+    :vartype streaming_jobs: azure.mgmt.streamanalytics.aio.operations.StreamingJobsOperations
     :ivar inputs: InputsOperations operations
-    :vartype inputs: stream_analytics_management_client.aio.operations.InputsOperations
+    :vartype inputs: azure.mgmt.streamanalytics.aio.operations.InputsOperations
     :ivar outputs: OutputsOperations operations
-    :vartype outputs: stream_analytics_management_client.aio.operations.OutputsOperations
+    :vartype outputs: azure.mgmt.streamanalytics.aio.operations.OutputsOperations
     :ivar transformations: TransformationsOperations operations
-    :vartype transformations:
-     stream_analytics_management_client.aio.operations.TransformationsOperations
+    :vartype transformations: azure.mgmt.streamanalytics.aio.operations.TransformationsOperations
     :ivar functions: FunctionsOperations operations
-    :vartype functions: stream_analytics_management_client.aio.operations.FunctionsOperations
+    :vartype functions: azure.mgmt.streamanalytics.aio.operations.FunctionsOperations
     :ivar subscriptions: SubscriptionsOperations operations
-    :vartype subscriptions:
-     stream_analytics_management_client.aio.operations.SubscriptionsOperations
+    :vartype subscriptions: azure.mgmt.streamanalytics.aio.operations.SubscriptionsOperations
     :ivar clusters: ClustersOperations operations
-    :vartype clusters: stream_analytics_management_client.aio.operations.ClustersOperations
+    :vartype clusters: azure.mgmt.streamanalytics.aio.operations.ClustersOperations
     :ivar private_endpoints: PrivateEndpointsOperations operations
     :vartype private_endpoints:
-     stream_analytics_management_client.aio.operations.PrivateEndpointsOperations
+     azure.mgmt.streamanalytics.aio.operations.PrivateEndpointsOperations
     :param credential: Credential needed for the client to connect to Azure.
     :type credential: ~azure.core.credentials_async.AsyncTokenCredential
     :param subscription_id: The ID of the target subscription.

sdk/streamanalytics/azure-mgmt-streamanalytics/azure/mgmt/streamanalytics/aio/operations/_clusters_operations.py

@@ -33,7 +33,7 @@ class ClustersOperations:
     instantiates it for you and attaches it as an attribute.
 
     :ivar models: Alias to model classes used in this operation group.
-    :type models: ~stream_analytics_management_client.models
+    :type models: ~azure.mgmt.streamanalytics.models
     :param client: Client for service requests.
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
@@ -119,7 +119,7 @@ async def begin_create_or_update(
         :type cluster_name: str
         :param cluster: The definition of the cluster that will be used to create a new cluster or
          replace the existing one.
-        :type cluster: ~stream_analytics_management_client.models.Cluster
+        :type cluster: ~azure.mgmt.streamanalytics.models.Cluster
         :param if_match: The ETag of the resource. Omit this value to always overwrite the current
          record set. Specify the last-seen ETag value to prevent accidentally overwriting concurrent
          changes.
@@ -137,7 +137,7 @@ async def begin_create_or_update(
          Retry-After header is present.
         :return: An instance of AsyncLROPoller that returns either Cluster or the result of
          cls(response)
-        :rtype: ~azure.core.polling.AsyncLROPoller[~stream_analytics_management_client.models.Cluster]
+        :rtype: ~azure.core.polling.AsyncLROPoller[~azure.mgmt.streamanalytics.models.Cluster]
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         content_type = kwargs.pop('content_type', "application/json")  # type: Optional[str]
@@ -251,7 +251,7 @@ async def begin_update(
         :type cluster_name: str
         :param cluster: The properties specified here will overwrite the corresponding properties in
          the existing cluster (ie. Those properties will be updated).
-        :type cluster: ~stream_analytics_management_client.models.Cluster
+        :type cluster: ~azure.mgmt.streamanalytics.models.Cluster
         :param if_match: The ETag of the resource. Omit this value to always overwrite the current
          record set. Specify the last-seen ETag value to prevent accidentally overwriting concurrent
          changes.
@@ -266,7 +266,7 @@ async def begin_update(
          Retry-After header is present.
         :return: An instance of AsyncLROPoller that returns either Cluster or the result of
          cls(response)
-        :rtype: ~azure.core.polling.AsyncLROPoller[~stream_analytics_management_client.models.Cluster]
+        :rtype: ~azure.core.polling.AsyncLROPoller[~azure.mgmt.streamanalytics.models.Cluster]
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         content_type = kwargs.pop('content_type', "application/json")  # type: Optional[str]
@@ -327,7 +327,7 @@ async def get(
         :type cluster_name: str
         :keyword callable cls: A custom type or function that will be passed the direct response
         :return: Cluster, or the result of cls(response)
-        :rtype: ~stream_analytics_management_client.models.Cluster
+        :rtype: ~azure.mgmt.streamanalytics.models.Cluster
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         cls = kwargs.pop('cls', None)  # type: ClsType["_models.Cluster"]
@@ -470,7 +470,7 @@ def list_by_subscription(
         :keyword callable cls: A custom type or function that will be passed the direct response
         :return: An iterator like instance of either ClusterListResult or the result of cls(response)
         :rtype:
-         ~azure.core.async_paging.AsyncItemPaged[~stream_analytics_management_client.models.ClusterListResult]
+         ~azure.core.async_paging.AsyncItemPaged[~azure.mgmt.streamanalytics.models.ClusterListResult]
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         cls = kwargs.pop('cls', None)  # type: ClsType["_models.ClusterListResult"]
@@ -538,7 +538,7 @@ def list_by_resource_group(
         :keyword callable cls: A custom type or function that will be passed the direct response
         :return: An iterator like instance of either ClusterListResult or the result of cls(response)
         :rtype:
-         ~azure.core.async_paging.AsyncItemPaged[~stream_analytics_management_client.models.ClusterListResult]
+         ~azure.core.async_paging.AsyncItemPaged[~azure.mgmt.streamanalytics.models.ClusterListResult]
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         cls = kwargs.pop('cls', None)  # type: ClsType["_models.ClusterListResult"]
@@ -612,7 +612,7 @@ def list_streaming_jobs(
         :return: An iterator like instance of either ClusterJobListResult or the result of
          cls(response)
         :rtype:
-         ~azure.core.async_paging.AsyncItemPaged[~stream_analytics_management_client.models.ClusterJobListResult]
+         ~azure.core.async_paging.AsyncItemPaged[~azure.mgmt.streamanalytics.models.ClusterJobListResult]
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         cls = kwargs.pop('cls', None)  # type: ClsType["_models.ClusterJobListResult"]

sdk/streamanalytics/azure-mgmt-streamanalytics/azure/mgmt/streamanalytics/aio/operations/_functions_operations.py

@@ -33,7 +33,7 @@ class FunctionsOperations:
     instantiates it for you and attaches it as an attribute.
 
     :ivar models: Alias to model classes used in this operation group.
-    :type models: ~stream_analytics_management_client.models
+    :type models: ~azure.mgmt.streamanalytics.models
     :param client: Client for service requests.
     :param config: Configuration of service client.
     :param serializer: An object model serializer.
@@ -69,7 +69,7 @@ async def create_or_replace(
         :type function_name: str
         :param function: The definition of the function that will be used to create a new function or
          replace the existing one under the streaming job.
-        :type function: ~stream_analytics_management_client.models.Function
+        :type function: ~azure.mgmt.streamanalytics.models.Function
         :param if_match: The ETag of the function. Omit this value to always overwrite the current
          function. Specify the last-seen ETag value to prevent accidentally overwriting concurrent
          changes.
@@ -79,7 +79,7 @@ async def create_or_replace(
         :type if_none_match: str
         :keyword callable cls: A custom type or function that will be passed the direct response
         :return: Function, or the result of cls(response)
-        :rtype: ~stream_analytics_management_client.models.Function
+        :rtype: ~azure.mgmt.streamanalytics.models.Function
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         cls = kwargs.pop('cls', None)  # type: ClsType["_models.Function"]
@@ -157,14 +157,14 @@ async def update(
          corresponding properties in the existing function (ie. Those properties will be updated). Any
          properties that are set to null here will mean that the corresponding property in the existing
          function will remain the same and not change as a result of this PATCH operation.
-        :type function: ~stream_analytics_management_client.models.Function
+        :type function: ~azure.mgmt.streamanalytics.models.Function
         :param if_match: The ETag of the function. Omit this value to always overwrite the current
          function. Specify the last-seen ETag value to prevent accidentally overwriting concurrent
          changes.
         :type if_match: str
         :keyword callable cls: A custom type or function that will be passed the direct response
         :return: Function, or the result of cls(response)
-        :rtype: ~stream_analytics_management_client.models.Function
+        :rtype: ~azure.mgmt.streamanalytics.models.Function
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         cls = kwargs.pop('cls', None)  # type: ClsType["_models.Function"]
@@ -281,7 +281,7 @@ async def get(
         :type function_name: str
         :keyword callable cls: A custom type or function that will be passed the direct response
         :return: Function, or the result of cls(response)
-        :rtype: ~stream_analytics_management_client.models.Function
+        :rtype: ~azure.mgmt.streamanalytics.models.Function
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         cls = kwargs.pop('cls', None)  # type: ClsType["_models.Function"]
@@ -343,7 +343,7 @@ def list_by_streaming_job(
         :keyword callable cls: A custom type or function that will be passed the direct response
         :return: An iterator like instance of either FunctionListResult or the result of cls(response)
         :rtype:
-         ~azure.core.async_paging.AsyncItemPaged[~stream_analytics_management_client.models.FunctionListResult]
+         ~azure.core.async_paging.AsyncItemPaged[~azure.mgmt.streamanalytics.models.FunctionListResult]
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         cls = kwargs.pop('cls', None)  # type: ClsType["_models.FunctionListResult"]
@@ -480,7 +480,7 @@ async def begin_test(
          this parameter can be left null to test the existing function as is or if specified, the
          properties specified will overwrite the corresponding properties in the existing function
          (exactly like a PATCH operation) and the resulting function will be tested.
-        :type function: ~stream_analytics_management_client.models.Function
+        :type function: ~azure.mgmt.streamanalytics.models.Function
         :keyword callable cls: A custom type or function that will be passed the direct response
         :keyword str continuation_token: A continuation token to restart a poller from a saved state.
         :keyword polling: By default, your polling method will be AsyncARMPolling. Pass in False for
@@ -492,7 +492,7 @@ async def begin_test(
         :return: An instance of AsyncLROPoller that returns either ResourceTestStatus or the result of
          cls(response)
         :rtype:
-         ~azure.core.polling.AsyncLROPoller[~stream_analytics_management_client.models.ResourceTestStatus]
+         ~azure.core.polling.AsyncLROPoller[~azure.mgmt.streamanalytics.models.ResourceTestStatus]
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         content_type = kwargs.pop('content_type', "application/json")  # type: Optional[str]
@@ -558,10 +558,10 @@ async def retrieve_default_definition(
         :param function_retrieve_default_definition_parameters: Parameters used to specify the type of
          function to retrieve the default definition for.
         :type function_retrieve_default_definition_parameters:
-         ~stream_analytics_management_client.models.FunctionRetrieveDefaultDefinitionParameters
+         ~azure.mgmt.streamanalytics.models.FunctionRetrieveDefaultDefinitionParameters
         :keyword callable cls: A custom type or function that will be passed the direct response
         :return: Function, or the result of cls(response)
-        :rtype: ~stream_analytics_management_client.models.Function
+        :rtype: ~azure.mgmt.streamanalytics.models.Function
         :raises: ~azure.core.exceptions.HttpResponseError
         """
         cls = kwargs.pop('cls', None)  # type: ClsType["_models.Function"]