Merge ~barryprice/spade/+git/spade:flake8 into spade:master

Proposed by Barry Price
Status: Superseded
Proposed branch: ~barryprice/spade/+git/spade:flake8
Merge into: spade:master
Prerequisite: ~barryprice/spade/+git/spade:master
Diff against target: 166 lines (+16/-15)
6 files modified
Makefile (+1/-1)
spade/AzureBucket.py (+2/-2)
spade/S3Bucket.py (+3/-3)
spade/Spade.py (+5/-5)
spade/SwiftBucket.py (+3/-3)
spade/spade.py (+2/-1)
Reviewer Review Type Date Requested Status
Spade Developers Pending
Review via email: mp+394569@code.launchpad.net

This proposal has been superseded by a proposal from 2020-11-27.

Commit message

Address all Flake8 errors bar complexity (noqa: C901)

To post a comment you must log in.
~barryprice/spade/+git/spade:flake8 updated
c85283a... by Barry Price

Typo

6817bc5... by Barry Price

Merge branch 'master' into flake8

Unmerged commits

6817bc5... by Barry Price

Merge branch 'master' into flake8

c85283a... by Barry Price

Typo

aa2d273... by Barry Price

Address all Flake8 errors bar complexity (noqa: C901)

7e34f18... by Barry Price

Modernise, switch to python3 exclusively

Preview Diff

[H/L] Next/Prev Comment, [J/K] Next/Prev File, [N/P] Next/Prev Hunk
diff --git a/Makefile b/Makefile
index d51fa68..03544a4 100644
--- a/Makefile
+++ b/Makefile
@@ -9,7 +9,7 @@ lint: blacken
9 @tox -e lint9 @tox -e lint
1010
11clean:11clean:
12 @echo "Cleaninf files"12 @echo "Cleaning files"
13 @git clean -fXd13 @git clean -fXd
1414
15snap: snap_clean15snap: snap_clean
diff --git a/spade/AzureBucket.py b/spade/AzureBucket.py
index 92bf430..0f7a62d 100644
--- a/spade/AzureBucket.py
+++ b/spade/AzureBucket.py
@@ -239,7 +239,7 @@ class AzureBucket():
239 newStandardMetadata[k] = v239 newStandardMetadata[k] = v
240 if not overwrite:240 if not overwrite:
241 for k, v in m.userMetadata.items():241 for k, v in m.userMetadata.items():
242 newUserMetadata[USER_META_PREFIX + k] = v242 newUserMetadata[USER_META_PREFIX + k] = v
243243
244 # Add new ones244 # Add new ones
245 for k, v in metadata.items():245 for k, v in metadata.items():
@@ -318,7 +318,7 @@ class AzureBucket():
318 body=xml,318 body=xml,
319 method="PUT")319 method="PUT")
320 if not response.get("status") == "201":320 if not response.get("status") == "201":
321 raise BucketError("Azure Failed to upload blocklist")321 raise BucketError("Azure Failed to upload blocklist")
322 return322 return
323323
324 def putObject(self, bucketName, objectName, src, size, blockSize=DEFAULT_BLOCKSIZE):324 def putObject(self, bucketName, objectName, src, size, blockSize=DEFAULT_BLOCKSIZE):
diff --git a/spade/S3Bucket.py b/spade/S3Bucket.py
index 90e6a84..6d3036e 100644
--- a/spade/S3Bucket.py
+++ b/spade/S3Bucket.py
@@ -61,7 +61,7 @@ class S3Bucket():
61 {'name': 'us-west-1', 'endpoint': 's3-us-west-1.amazonaws.com'},61 {'name': 'us-west-1', 'endpoint': 's3-us-west-1.amazonaws.com'},
62 {'name': 'us-west-2', 'endpoint': 's3-us-west-2.amazonaws.com'},62 {'name': 'us-west-2', 'endpoint': 's3-us-west-2.amazonaws.com'},
63 {'name': 'us-east-1', 'endpoint': 's3.amazonaws.com'},63 {'name': 'us-east-1', 'endpoint': 's3.amazonaws.com'},
64 ]64 ]
6565
66 self.base_fields = set(['content-length', 'content-language', 'content-disposition',66 self.base_fields = set(['content-length', 'content-language', 'content-disposition',
67 'content-encoding', 'expires', 'content-md5', 'last-modified',67 'content-encoding', 'expires', 'content-md5', 'last-modified',
@@ -325,7 +325,7 @@ class S3Bucket():
325 else:325 else:
326 return aclData["s3_id"]326 return aclData["s3_id"]
327327
328 def getAcls(self, bucketName, objectName=None):328 def getAcls(self, bucketName, objectName=None): # noqa: C901
329 self.confirmRegion(bucketName)329 self.confirmRegion(bucketName)
330 try:330 try:
331 bucket = self.s3.get_bucket(bucketName)331 bucket = self.s3.get_bucket(bucketName)
@@ -366,7 +366,7 @@ class S3Bucket():
366366
367 return acls367 return acls
368368
369 def setAcls(self, bucketName, acls, objectName=None):369 def setAcls(self, bucketName, acls, objectName=None): # noqa: C901
370 self.confirmRegion(bucketName)370 self.confirmRegion(bucketName)
371 try:371 try:
372 bucket = self.s3.get_bucket(bucketName)372 bucket = self.s3.get_bucket(bucketName)
diff --git a/spade/Spade.py b/spade/Spade.py
index b33edb0..b8f4b12 100644
--- a/spade/Spade.py
+++ b/spade/Spade.py
@@ -69,7 +69,7 @@ class Bucket():
69 raise BucketError("Data is not in bzip2 format")69 raise BucketError("Data is not in bzip2 format")
70 else:70 else:
71 raise BucketError("Unknown IO error")71 raise BucketError("Unknown IO error")
72 except lzma.LZMAError as e:72 except lzma.LZMAError:
73 if "Input format not supported by decoder":73 if "Input format not supported by decoder":
74 raise BucketError("Data is not in xz/lzma format")74 raise BucketError("Data is not in xz/lzma format")
75 else:75 else:
@@ -150,7 +150,7 @@ class Bucket():
150 ret.output.append(retElement)150 ret.output.append(retElement)
151 return ret151 return ret
152152
153 def ls(self, rawArgs):153 def ls(self, rawArgs): # noqa: C901
154 ret = Result()154 ret = Result()
155 parser = argparse.ArgumentParser(description="Bucket ls")155 parser = argparse.ArgumentParser(description="Bucket ls")
156 parser.add_argument("-l", dest="long", action="store_true")156 parser.add_argument("-l", dest="long", action="store_true")
@@ -237,7 +237,7 @@ class Bucket():
237 ret.output = [data.decode("utf-8")]237 ret.output = [data.decode("utf-8")]
238 f.close()238 f.close()
239239
240 def grep(self, rawArgs):240 def grep(self, rawArgs): # noqa: C901
241 ret = Result()241 ret = Result()
242 parser = argparse.ArgumentParser(description="Bucket grep")242 parser = argparse.ArgumentParser(description="Bucket grep")
243 parser.add_argument("-e", dest="regex", action="store_true", help="Allow regexes in the search")243 parser.add_argument("-e", dest="regex", action="store_true", help="Allow regexes in the search")
@@ -374,7 +374,7 @@ class Bucket():
374 ret.output.append(e)374 ret.output.append(e)
375 return ret375 return ret
376376
377 def cp(self, rawArgs):377 def cp(self, rawArgs): # noqa: C901
378 ret = Result()378 ret = Result()
379 parser = argparse.ArgumentParser(description="Bucket cp")379 parser = argparse.ArgumentParser(description="Bucket cp")
380 parser.add_argument(dest="src")380 parser.add_argument(dest="src")
@@ -581,7 +581,7 @@ class Bucket():
581581
582 # FIXME: Need to pass add/remove to bucket acl functions instead of582 # FIXME: Need to pass add/remove to bucket acl functions instead of
583 # just the processed acls list583 # just the processed acls list
584 def acls(self, rawArgs):584 def acls(self, rawArgs): # noqa: C901
585 ret = Result()585 ret = Result()
586 parser = argparse.ArgumentParser(description="Bucket ACLs")586 parser = argparse.ArgumentParser(description="Bucket ACLs")
587 parser.add_argument("-a", "--add", dest="add", action="append", default=[])587 parser.add_argument("-a", "--add", dest="add", action="append", default=[])
diff --git a/spade/SwiftBucket.py b/spade/SwiftBucket.py
index f49f2b9..2125b85 100644
--- a/spade/SwiftBucket.py
+++ b/spade/SwiftBucket.py
@@ -108,7 +108,7 @@ class SwiftBucket():
108 co.rawMetadata[k] = v108 co.rawMetadata[k] = v
109 return co109 return co
110110
111 def setBucketMetadata(self, bucketName, metadata, overwrite=False):111 def setBucketMetadata(self, bucketName, metadata, overwrite=False): # noqa: C901
112 systemMetadata = ["content-type", "x-container-bytes-used",112 systemMetadata = ["content-type", "x-container-bytes-used",
113 "x-container-object-count:", "x-timestamp"]113 "x-container-object-count:", "x-timestamp"]
114 newMetadata = {}114 newMetadata = {}
@@ -237,7 +237,7 @@ class SwiftBucket():
237 headers = {237 headers = {
238 'x-object-manifest': manifest,238 'x-object-manifest': manifest,
239 'x-object-meta-mtime': mtime,239 'x-object-meta-mtime': mtime,
240 }240 }
241 try:241 try:
242 self.swift.put_object(bucketName,242 self.swift.put_object(bucketName,
243 objectName,243 objectName,
@@ -265,7 +265,7 @@ class SwiftBucket():
265 def open(self, bucketName, objectName, blockSize=DEFAULT_BLOCKSIZE):265 def open(self, bucketName, objectName, blockSize=DEFAULT_BLOCKSIZE):
266 return ObjectIO(self, bucketName, objectName, blockSize)266 return ObjectIO(self, bucketName, objectName, blockSize)
267267
268 def deleteObject(self, bucketName, objectName):268 def deleteObject(self, bucketName, objectName): # noqa: C901
269 try:269 try:
270 metadata = self.getObjectMetadata(bucketName, objectName)270 metadata = self.getObjectMetadata(bucketName, objectName)
271 except BucketError:271 except BucketError:
diff --git a/spade/spade.py b/spade/spade.py
index c000805..1b5811c 100755
--- a/spade/spade.py
+++ b/spade/spade.py
@@ -8,7 +8,7 @@ import argparse
8from spade.Spade import Bucket8from spade.Spade import Bucket
99
1010
11def main():11def main(): # noqa: C901
12 parser = argparse.ArgumentParser(description="Bucket manipulation")12 parser = argparse.ArgumentParser(description="Bucket manipulation")
13 parser.add_argument("--configfile", dest="configfile", help="Config file")13 parser.add_argument("--configfile", dest="configfile", help="Config file")
14 parser.add_argument(dest="cmd")14 parser.add_argument(dest="cmd")
@@ -157,5 +157,6 @@ def main():
157 else:157 else:
158 print("Unknown command {}".format(args.cmd), file=sys.stderr)158 print("Unknown command {}".format(args.cmd), file=sys.stderr)
159159
160
160if __name__ == "__main__":161if __name__ == "__main__":
161 main()162 main()

Subscribers

People subscribed via source and target branches

to all changes: