@@ -71,7 +71,7 @@ def parse_resource(
71
71
return None # type: ignore
72
72
73
73
74
- class SecurityDomainClientDownloadPolling (OperationResourcePolling ):
74
+ class SecurityDomainDownloadPolling (OperationResourcePolling ):
75
75
def __init__ (self ) -> None :
76
76
self ._polling_url = ""
77
77
super ().__init__ (operation_location_header = "azure-asyncoperation" )
@@ -93,7 +93,7 @@ def set_initial_status(self, pipeline_response: "PipelineResponse") -> str:
93
93
raise OperationFailed ("Operation failed or canceled" )
94
94
95
95
96
- class SecurityDomainClientDownloadPollingMethod (PollingTerminationMixin , LROBasePolling ):
96
+ class SecurityDomainDownloadPollingMethod (PollingTerminationMixin , LROBasePolling ):
97
97
def initialize (
98
98
self ,
99
99
client : PipelineClient [Any , Any ],
@@ -118,10 +118,10 @@ def get_long_running_output(pipeline_response):
118
118
response_headers = {}
119
119
response = pipeline_response .http_response
120
120
deserializer = Deserializer ()
121
- response_headers ["Azure-AsyncOperation" ] = deserializer ._deserialize (
121
+ response_headers ["Azure-AsyncOperation" ] = deserializer ._deserialize ( # pylint: disable=protected-access
122
122
"str" , response .headers .get ("Azure-AsyncOperation" )
123
123
)
124
- response_headers ["Retry-After" ] = deserializer ._deserialize ("int" , response .headers .get ("Retry-After" ))
124
+ response_headers ["Retry-After" ] = deserializer ._deserialize ("int" , response .headers .get ("Retry-After" )) # pylint: disable=protected-access
125
125
126
126
return _deserialize (SecurityDomainObject , response .json ())
127
127
@@ -137,7 +137,7 @@ def resource(self) -> SecurityDomainObject:
137
137
return cast (SecurityDomainObject , self .parse_resource (self ._initial_response ))
138
138
139
139
140
- class SecurityDomainClientUploadPolling ( SecurityDomainClientDownloadPolling ):
140
+ class SecurityDomainUploadPolling ( SecurityDomainDownloadPolling ):
141
141
def set_initial_status (self , pipeline_response : "PipelineResponse" ) -> str :
142
142
response : HttpResponse = pipeline_response .http_response
143
143
self ._polling_url = response .headers ["azure-asyncoperation" ]
@@ -147,7 +147,7 @@ def set_initial_status(self, pipeline_response: "PipelineResponse") -> str:
147
147
raise OperationFailed ("Operation failed or canceled" )
148
148
149
149
150
- class SecurityDomainClientUploadPollingMethod (PollingTerminationMixin , LROBasePolling ):
150
+ class SecurityDomainUploadPollingMethod (PollingTerminationMixin , LROBasePolling ):
151
151
def initialize (
152
152
self ,
153
153
client : PipelineClient [Any , Any ],
@@ -172,10 +172,10 @@ def get_long_running_output(pipeline_response):
172
172
response_headers = {}
173
173
response = pipeline_response .http_response
174
174
deserializer = Deserializer ()
175
- response_headers ["Azure-AsyncOperation" ] = deserializer ._deserialize (
175
+ response_headers ["Azure-AsyncOperation" ] = deserializer ._deserialize ( # pylint: disable=protected-access
176
176
"str" , response .headers .get ("Azure-AsyncOperation" )
177
177
)
178
- response_headers ["Retry-After" ] = deserializer ._deserialize ("int" , response .headers .get ("Retry-After" ))
178
+ response_headers ["Retry-After" ] = deserializer ._deserialize ("int" , response .headers .get ("Retry-After" )) # pylint: disable=protected-access
179
179
180
180
return _deserialize (SecurityDomainOperationStatus , response .json ())
181
181
0 commit comments