[Notes] [Git][BuildStream/buildstream][danielsilverstone-ct/fix-lint-issues] 5 commits: _artifactcache/cascache.py: Refactor slightly for indentation

[Daniel <gitlab mg gitlab com>]

Title: GitLab

Daniel pushed to branch danielsilverstone-ct/fix-lint-issues at BuildStream / buildstream

Commits:

• f228c739
  by Daniel Silverstone at 2018-10-24T10:09:22Z

  _artifactcache/cascache.py: Refactor slightly for indentation
  
  Correct some multi-line conditional indentation by slight refactor
  if necessary.
  
  Signed-off-by: Daniel Silverstone <daniel silverstone codethink co uk>
  

• 2a7da007
  by Daniel Silverstone at 2018-10-24T10:12:25Z

  _artifactcache/cascache.py: Silence len(SEQUENCE) as condition warnings
  
  The lint tool dislikes the use of `if len(SEQ) == 0` type statements
  because nominally `len(SEQ)` may be more expensive than `bool(SEQ)`.
  
  Signed-off-by: Daniel Silverstone <daniel silverstone codethink co uk>
  

• 4b1b0ebf
  by Daniel Silverstone at 2018-10-24T10:17:18Z

  _artifactcache/cascache.py: Prepare attributes in __init__
  
  Python linters prefer that attributes are defined in __init__ rather
  than left to later routines.
  
  Signed-off-by: Daniel Silverstone <daniel silverstone codethink co uk>
  

• ae99dbca
  by Daniel Silverstone at 2018-10-24T10:18:07Z

  _artifactcache/cascache.py: Remove unused imports
  
  The imports of `Message` and `MessageType` were unused.
  
  Signed-off-by: Daniel Silverstone <daniel silverstone codethink co uk>
  

• 1812262f
  by Daniel Silverstone at 2018-10-24T10:28:43Z

  _artifactcache/cascache.py: Cleanup lint warning about indexing
  
  In order to quieten the linter, and to make a more correct comparison,
  we switch to using the `Code.OK` enumeration from `google.rpc.Code`
  
  Signed-off-by: Daniel Silverstone <daniel silverstone codethink co uk>
  

1 changed file:

• buildstream/_artifactcache/cascache.py

Changes:

buildstream/_artifactcache/cascache.py

---

...	...	@@ -33,11 +33,11 @@ import grpc
33	33
34	34	from .. import _yaml
35	35
	36	+from .._protos.google.rpc import code_pb2
36	37	from .._protos.google.bytestream import bytestream_pb2, bytestream_pb2_grpc
37	38	from .._protos.build.bazel.remote.execution.v2 import remote_execution_pb2, remote_execution_pb2_grpc
38	39	from .._protos.buildstream.v2 import buildstream_pb2, buildstream_pb2_grpc
39	40
40		-from .._message import MessageType, Message
41	41	from .. import _signals, utils
42	42	from .._exceptions import ArtifactError
43	43
...	...	@@ -81,8 +81,9 @@ class CASCache(ArtifactCache):
81	81	################################################
82	82
83	83	def preflight(self):
84		- if (not os.path.isdir(os.path.join(self.casdir, 'refs', 'heads')) or
85		- not os.path.isdir(os.path.join(self.casdir, 'objects'))):
	84	+ headdir = os.path.join(self.casdir, 'refs', 'heads')
	85	+ objdir = os.path.join(self.casdir, 'objects')
	86	+ if not (os.path.isdir(headdir) and os.path.isdir(objdir)):
86	87	raise ArtifactError("CAS repository check failed for '{}'"
87	88	.format(self.casdir))
88	89
...	...	@@ -918,7 +919,7 @@ class CASCache(ArtifactCache):
918	919	# Skip download, already in local cache.
919	920	pass
920	921	elif (digest.size_bytes >= remote.max_batch_total_size_bytes or
921		- not remote.batch_read_supported):
	922	+ not remote.batch_read_supported):
922	923	# Too large for batch request, download in independent request.
923	924	self._ensure_blob(remote, digest)
924	925	in_local_cache = True
...	...	@@ -958,7 +959,7 @@ class CASCache(ArtifactCache):
958	959	batch = _CASBatchRead(remote)
959	960
960	961	while len(fetch_queue) + len(fetch_next_queue) > 0:
961		- if len(fetch_queue) == 0:
	962	+ if not fetch_queue:
962	963	batch = self._fetch_directory_batch(remote, batch, fetch_queue, fetch_next_queue)
963	964
964	965	dir_digest = fetch_queue.pop(0)
...	...	@@ -1087,6 +1088,10 @@ class _CASRemote():
1087	1088	self.bytestream = None
1088	1089	self.cas = None
1089	1090	self.ref_storage = None
	1091	+ self.batch_update_supported = None
	1092	+ self.batch_read_supported = None
	1093	+ self.capabilities = None
	1094	+ self.max_batch_total_size_bytes = None
1090	1095
1091	1096	def init(self):
1092	1097	if not self._initialized:
...	...	@@ -1191,13 +1196,13 @@ class _CASBatchRead():
1191	1196	assert not self._sent
1192	1197	self._sent = True
1193	1198
1194		- if len(self._request.digests) == 0:
	1199	+ if not self._request.digests:
1195	1200	return
1196	1201
1197	1202	batch_response = self._remote.cas.BatchReadBlobs(self._request)
1198	1203
1199	1204	for response in batch_response.responses:
1200		- if response.status.code != grpc.StatusCode.OK.value[0]:
	1205	+ if response.status.code != code_pb2.OK:
1201	1206	raise ArtifactError("Failed to download blob {}: {}".format(
1202	1207	response.digest.hash, response.status.code))
1203	1208	if response.digest.size_bytes != len(response.data):
...	...	@@ -1236,13 +1241,13 @@ class _CASBatchUpdate():
1236	1241	assert not self._sent
1237	1242	self._sent = True
1238	1243
1239		- if len(self._request.requests) == 0:
	1244	+ if not self._request.requests:
1240	1245	return
1241	1246
1242	1247	batch_response = self._remote.cas.BatchUpdateBlobs(self._request)
1243	1248
1244	1249	for response in batch_response.responses:
1245		- if response.status.code != grpc.StatusCode.OK.value[0]:
	1250	+ if response.status.code != code_pb2.OK:
1246	1251	raise ArtifactError("Failed to upload blob {}: {}".format(
1247	1252	response.digest.hash, response.status.code))
1248	1253

—
View it on GitLab.
You're receiving this email because of your account on gitlab.com. If you'd like to receive fewer emails, you can adjust your notification settings.