@@ -121,8 +121,9 @@ async def get(self, resource_group_name: str, resource_name: str, **kwargs: Any)
121
121
request = _convert_request (request )
122
122
request .url = self ._client .format_url (request .url )
123
123
124
+ _stream = False
124
125
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
125
- request , stream = False , ** kwargs
126
+ request , stream = _stream , ** kwargs
126
127
)
127
128
128
129
response = pipeline_response .http_response
@@ -188,8 +189,9 @@ async def _create_or_update_initial(
188
189
request = _convert_request (request )
189
190
request .url = self ._client .format_url (request .url )
190
191
192
+ _stream = False
191
193
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
192
- request , stream = False , ** kwargs
194
+ request , stream = _stream , ** kwargs
193
195
)
194
196
195
197
response = pipeline_response .http_response
@@ -415,8 +417,9 @@ async def _delete_initial(
415
417
request = _convert_request (request )
416
418
request .url = self ._client .format_url (request .url )
417
419
420
+ _stream = False
418
421
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
419
- request , stream = False , ** kwargs
422
+ request , stream = _stream , ** kwargs
420
423
)
421
424
422
425
response = pipeline_response .http_response
@@ -584,8 +587,9 @@ async def extract_data(pipeline_response):
584
587
async def get_next (next_link = None ):
585
588
request = prepare_request (next_link )
586
589
590
+ _stream = False
587
591
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
588
- request , stream = False , ** kwargs
592
+ request , stream = _stream , ** kwargs
589
593
)
590
594
response = pipeline_response .http_response
591
595
@@ -673,8 +677,9 @@ async def extract_data(pipeline_response):
673
677
async def get_next (next_link = None ):
674
678
request = prepare_request (next_link )
675
679
680
+ _stream = False
676
681
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
677
- request , stream = False , ** kwargs
682
+ request , stream = _stream , ** kwargs
678
683
)
679
684
response = pipeline_response .http_response
680
685
@@ -734,8 +739,9 @@ async def get_stats(
734
739
request = _convert_request (request )
735
740
request .url = self ._client .format_url (request .url )
736
741
742
+ _stream = False
737
743
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
738
- request , stream = False , ** kwargs
744
+ request , stream = _stream , ** kwargs
739
745
)
740
746
741
747
response = pipeline_response .http_response
@@ -832,8 +838,9 @@ async def extract_data(pipeline_response):
832
838
async def get_next (next_link = None ):
833
839
request = prepare_request (next_link )
834
840
841
+ _stream = False
835
842
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
836
- request , stream = False , ** kwargs
843
+ request , stream = _stream , ** kwargs
837
844
)
838
845
response = pipeline_response .http_response
839
846
@@ -929,8 +936,9 @@ async def extract_data(pipeline_response):
929
936
async def get_next (next_link = None ):
930
937
request = prepare_request (next_link )
931
938
939
+ _stream = False
932
940
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
933
- request , stream = False , ** kwargs
941
+ request , stream = _stream , ** kwargs
934
942
)
935
943
response = pipeline_response .http_response
936
944
@@ -997,8 +1005,9 @@ async def get_event_hub_consumer_group(
997
1005
request = _convert_request (request )
998
1006
request .url = self ._client .format_url (request .url )
999
1007
1008
+ _stream = False
1000
1009
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
1001
- request , stream = False , ** kwargs
1010
+ request , stream = _stream , ** kwargs
1002
1011
)
1003
1012
1004
1013
response = pipeline_response .http_response
@@ -1069,8 +1078,9 @@ async def create_event_hub_consumer_group(
1069
1078
request = _convert_request (request )
1070
1079
request .url = self ._client .format_url (request .url )
1071
1080
1081
+ _stream = False
1072
1082
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
1073
- request , stream = False , ** kwargs
1083
+ request , stream = _stream , ** kwargs
1074
1084
)
1075
1085
1076
1086
response = pipeline_response .http_response
@@ -1141,8 +1151,9 @@ async def delete_event_hub_consumer_group( # pylint: disable=inconsistent-retur
1141
1151
request = _convert_request (request )
1142
1152
request .url = self ._client .format_url (request .url )
1143
1153
1154
+ _stream = False
1144
1155
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
1145
- request , stream = False , ** kwargs
1156
+ request , stream = _stream , ** kwargs
1146
1157
)
1147
1158
1148
1159
response = pipeline_response .http_response
@@ -1236,8 +1247,9 @@ async def extract_data(pipeline_response):
1236
1247
async def get_next (next_link = None ):
1237
1248
request = prepare_request (next_link )
1238
1249
1250
+ _stream = False
1239
1251
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
1240
- request , stream = False , ** kwargs
1252
+ request , stream = _stream , ** kwargs
1241
1253
)
1242
1254
response = pipeline_response .http_response
1243
1255
@@ -1302,8 +1314,9 @@ async def get_job(
1302
1314
request = _convert_request (request )
1303
1315
request .url = self ._client .format_url (request .url )
1304
1316
1317
+ _stream = False
1305
1318
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
1306
- request , stream = False , ** kwargs
1319
+ request , stream = _stream , ** kwargs
1307
1320
)
1308
1321
1309
1322
response = pipeline_response .http_response
@@ -1400,8 +1413,9 @@ async def extract_data(pipeline_response):
1400
1413
async def get_next (next_link = None ):
1401
1414
request = prepare_request (next_link )
1402
1415
1416
+ _stream = False
1403
1417
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
1404
- request , stream = False , ** kwargs
1418
+ request , stream = _stream , ** kwargs
1405
1419
)
1406
1420
response = pipeline_response .http_response
1407
1421
@@ -1513,8 +1527,9 @@ async def check_name_availability(
1513
1527
request = _convert_request (request )
1514
1528
request .url = self ._client .format_url (request .url )
1515
1529
1530
+ _stream = False
1516
1531
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
1517
- request , stream = False , ** kwargs
1532
+ request , stream = _stream , ** kwargs
1518
1533
)
1519
1534
1520
1535
response = pipeline_response .http_response
@@ -1613,8 +1628,9 @@ async def extract_data(pipeline_response):
1613
1628
async def get_next (next_link = None ):
1614
1629
request = prepare_request (next_link )
1615
1630
1631
+ _stream = False
1616
1632
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
1617
- request , stream = False , ** kwargs
1633
+ request , stream = _stream , ** kwargs
1618
1634
)
1619
1635
response = pipeline_response .http_response
1620
1636
@@ -1679,8 +1695,9 @@ async def get_keys_for_key_name(
1679
1695
request = _convert_request (request )
1680
1696
request .url = self ._client .format_url (request .url )
1681
1697
1698
+ _stream = False
1682
1699
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
1683
- request , stream = False , ** kwargs
1700
+ request , stream = _stream , ** kwargs
1684
1701
)
1685
1702
1686
1703
response = pipeline_response .http_response
@@ -1839,8 +1856,9 @@ async def export_devices(
1839
1856
request = _convert_request (request )
1840
1857
request .url = self ._client .format_url (request .url )
1841
1858
1859
+ _stream = False
1842
1860
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
1843
- request , stream = False , ** kwargs
1861
+ request , stream = _stream , ** kwargs
1844
1862
)
1845
1863
1846
1864
response = pipeline_response .http_response
@@ -1999,8 +2017,9 @@ async def import_devices(
1999
2017
request = _convert_request (request )
2000
2018
request .url = self ._client .format_url (request .url )
2001
2019
2020
+ _stream = False
2002
2021
pipeline_response : PipelineResponse = await self ._client ._pipeline .run ( # pylint: disable=protected-access
2003
- request , stream = False , ** kwargs
2022
+ request , stream = _stream , ** kwargs
2004
2023
)
2005
2024
2006
2025
response = pipeline_response .http_response
0 commit comments