@@ -246,6 +246,10 @@ def query(key, keyid, method='GET', params=None, headers=None,
246
246
# This can be used to save a binary object to disk
247
247
if local_file and method == 'GET' :
248
248
if result .status_code < 200 or result .status_code >= 300 :
249
+ if err_code in ['SlowDown' , 'ServiceUnavailable' , 'RequestTimeTooSkewed' ,
250
+ 'RequestTimeout' , 'OperationAborted' , 'InternalError' ]:
251
+ log .error ('Failed to get file. %s: %s' , err_code , err_msg )
252
+ return None
249
253
raise CommandExecutionError (
250
254
'Failed to get file. {0}: {1}' .format (err_code , err_msg ))
251
255
@@ -258,7 +262,7 @@ def query(key, keyid, method='GET', params=None, headers=None,
258
262
if result .status_code < 200 or result .status_code >= 300 :
259
263
if err_code in ['SlowDown' , 'ServiceUnavailable' , 'RequestTimeTooSkewed' ,
260
264
'RequestTimeout' , 'OperationAborted' , 'InternalError' ]:
261
- log .error ('Failed s3 operation: %s, %s' , err_code , err_msg )
265
+ log .error ('Failed s3 operation. %s: %s' , err_code , err_msg )
262
266
return None
263
267
raise CommandExecutionError (
264
268
'Failed s3 operation. {0}: {1}' .format (err_code , err_msg ))
0 commit comments