|
8 | 8 |
|
9 | 9 | from typing import Any, Optional, TYPE_CHECKING |
10 | 10 |
|
| 11 | +from azure.core.pipeline.transport import AsyncHttpResponse, HttpRequest |
11 | 12 | from azure.mgmt.core import AsyncARMPipelineClient |
12 | 13 | from msrest import Deserializer, Serializer |
13 | 14 |
|
|
31 | 32 | from .operations import GatewaysOperations |
32 | 33 | from .operations import SchemaOperations |
33 | 34 | from .operations import WorkspacePurgeOperations |
| 35 | +from .operations import TablesOperations |
34 | 36 | from .operations import ClustersOperations |
35 | 37 | from .operations import Operations |
36 | | -from .operations import TablesOperations |
37 | 38 | from .operations import WorkspacesOperations |
38 | 39 | from .operations import DeletedWorkspacesOperations |
39 | 40 | from .. import models |
@@ -72,12 +73,12 @@ class LogAnalyticsManagementClient(object): |
72 | 73 | :vartype schema: azure.mgmt.loganalytics.aio.operations.SchemaOperations |
73 | 74 | :ivar workspace_purge: WorkspacePurgeOperations operations |
74 | 75 | :vartype workspace_purge: azure.mgmt.loganalytics.aio.operations.WorkspacePurgeOperations |
| 76 | + :ivar tables: TablesOperations operations |
| 77 | + :vartype tables: azure.mgmt.loganalytics.aio.operations.TablesOperations |
75 | 78 | :ivar clusters: ClustersOperations operations |
76 | 79 | :vartype clusters: azure.mgmt.loganalytics.aio.operations.ClustersOperations |
77 | 80 | :ivar operations: Operations operations |
78 | 81 | :vartype operations: azure.mgmt.loganalytics.aio.operations.Operations |
79 | | - :ivar tables: TablesOperations operations |
80 | | - :vartype tables: azure.mgmt.loganalytics.aio.operations.TablesOperations |
81 | 82 | :ivar workspaces: WorkspacesOperations operations |
82 | 83 | :vartype workspaces: azure.mgmt.loganalytics.aio.operations.WorkspacesOperations |
83 | 84 | :ivar deleted_workspaces: DeletedWorkspacesOperations operations |
@@ -137,17 +138,34 @@ def __init__( |
137 | 138 | self._client, self._config, self._serialize, self._deserialize) |
138 | 139 | self.workspace_purge = WorkspacePurgeOperations( |
139 | 140 | self._client, self._config, self._serialize, self._deserialize) |
| 141 | + self.tables = TablesOperations( |
| 142 | + self._client, self._config, self._serialize, self._deserialize) |
140 | 143 | self.clusters = ClustersOperations( |
141 | 144 | self._client, self._config, self._serialize, self._deserialize) |
142 | 145 | self.operations = Operations( |
143 | 146 | self._client, self._config, self._serialize, self._deserialize) |
144 | | - self.tables = TablesOperations( |
145 | | - self._client, self._config, self._serialize, self._deserialize) |
146 | 147 | self.workspaces = WorkspacesOperations( |
147 | 148 | self._client, self._config, self._serialize, self._deserialize) |
148 | 149 | self.deleted_workspaces = DeletedWorkspacesOperations( |
149 | 150 | self._client, self._config, self._serialize, self._deserialize) |
150 | 151 |
|
| 152 | + async def _send_request(self, http_request: HttpRequest, **kwargs: Any) -> AsyncHttpResponse: |
| 153 | + """Runs the network request through the client's chained policies. |
| 154 | +
|
| 155 | + :param http_request: The network request you want to make. Required. |
| 156 | + :type http_request: ~azure.core.pipeline.transport.HttpRequest |
| 157 | + :keyword bool stream: Whether the response payload will be streamed. Defaults to True. |
| 158 | + :return: The response of your network call. Does not do error handling on your response. |
| 159 | + :rtype: ~azure.core.pipeline.transport.AsyncHttpResponse |
| 160 | + """ |
| 161 | + path_format_arguments = { |
| 162 | + 'subscriptionId': self._serialize.url("self._config.subscription_id", self._config.subscription_id, 'str', min_length=1), |
| 163 | + } |
| 164 | + http_request.url = self._client.format_url(http_request.url, **path_format_arguments) |
| 165 | + stream = kwargs.pop("stream", True) |
| 166 | + pipeline_response = await self._client._pipeline.run(http_request, stream=stream, **kwargs) |
| 167 | + return pipeline_response.http_response |
| 168 | + |
151 | 169 | async def close(self) -> None: |
152 | 170 | await self._client.close() |
153 | 171 |
|
|
0 commit comments