openstack/swift
Code Issues Proposed changes

func tests: Better-tolerate deleted containers in account listings

Browse Source 
Change-Id: I9217ba49d65cc29496b1532644bbef6b736074b8
This commit is contained in:
Tim Burke 2021-07-02 10:31:11 -07:00
parent 0e2adeb4ce
commit 7c0ff5797a
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
test/functional/swift_test_client.py
View File

@ -13,6 +13,7 @@
# See the License for the specific language governing permissions and # See the License for the specific language governing permissions and
# limitations under the License. # limitations under the License.
import functools
import io import io
import json import json
import os import os
@ -671,16 +672,18 @@ class Container(Base):
raise ResponseError(self.conn.response, 'POST', raise ResponseError(self.conn.response, 'POST',
self.conn.make_path(self.path)) self.conn.make_path(self.path))
def delete(self, hdrs=None, parms=None): def delete(self, hdrs=None, parms=None, tolerate_missing=False):
if hdrs is None: if hdrs is None:
hdrs = {} hdrs = {}
if parms is None: if parms is None:
parms = {} parms = {}
allowed_codes = (204, 404) if tolerate_missing else (204, )
return self.conn.make_request('DELETE', self.path, hdrs=hdrs, return self.conn.make_request('DELETE', self.path, hdrs=hdrs,
parms=parms) == 204 parms=parms) in allowed_codes
def delete_files(self): def delete_files(self, tolerate_missing=False):
for f in listing_items(self.files): for f in listing_items(functools.partial(
self.files, tolerate_missing=tolerate_missing)):
file_item = self.file(f) file_item = self.file(f)
if not file_item.delete(tolerate_missing=True): if not file_item.delete(tolerate_missing=True):
return False return False
@ -688,12 +691,13 @@ class Container(Base):
return listing_empty(self.files) return listing_empty(self.files)
def delete_recursive(self): def delete_recursive(self):
return self.delete_files() and self.delete() return self.delete_files(tolerate_missing=True) and \
self.delete(tolerate_missing=True)
def file(self, file_name): def file(self, file_name):
return File(self.conn, self.account, self.name, file_name) return File(self.conn, self.account, self.name, file_name)
def files(self, hdrs=None, parms=None, cfg=None): def files(self, hdrs=None, parms=None, cfg=None, tolerate_missing=False):
if hdrs is None: if hdrs is None:
hdrs = {} hdrs = {}
if parms is None: if parms is None:
@ -761,7 +765,7 @@ class Container(Base):
return [line.decode('utf-8') for line in lines] return [line.decode('utf-8') for line in lines]
else: else:
return [] return []
elif status == 204: elif status == 204 or (status == 404 and tolerate_missing):
return [] return []
raise ResponseError(self.conn.response, 'GET', raise ResponseError(self.conn.response, 'GET',