diff options
author | Pedro Alvarez <pedro.alvarez@codethink.co.uk> | 2016-03-08 12:28:54 +0000 |
---|---|---|
committer | Pedro Alvarez <pedro.alvarez@codethink.co.uk> | 2016-03-27 11:53:02 +0000 |
commit | 67dfff1a343a5337b831eaa9dc55c0b8908b7fb8 (patch) | |
tree | 65064469116f755f55f5e3a0ffe28c54926ba7c3 /gear/client.py | |
parent | 210625c3986a659f9d6053af0b8655279c6417a1 (diff) | |
download | morph-67dfff1a343a5337b831eaa9dc55c0b8908b7fb8.tar.gz |
Add debug code for build-graph failures
Change-Id: I72977b36a03b11120a2230a48e86fce356f7e3b2
Diffstat (limited to 'gear/client.py')
-rw-r--r-- | gear/client.py | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/gear/client.py b/gear/client.py index e9d818a6..63067f2d 100644 --- a/gear/client.py +++ b/gear/client.py @@ -28,9 +28,12 @@ class theController(): self.artifact = None self.build_started = False - def _process_build_graph(self, packet): + def _process_build_graph(self, build_graph): + print "=====" + print build_graph + print "=====" print "Decoding artifact received" - self.artifact = distbuild.decode_artifact_reference(job.data[-1]) + self.artifact = distbuild.decode_artifact_reference(build_graph) print "Decoding artifact received done" # Mark everything as unbuilt to begin with. We'll query the actua # state from the cache in self._query_cache_state(). @@ -76,6 +79,7 @@ class theController(): ''' def is_ready_to_build(artifact): + # Just in case the state is not set yet. try: is_ready = (artifact.state == UNBUILT and all(a.state == BUILT @@ -160,7 +164,7 @@ class BuildGraphClient(gear.Client): def handleWorkComplete(self, packet): job = super(BuildGraphClient, self).handleWorkComplete(packet) print "workcomplete" - self.controller._process_build_graph(packet) + self.controller._process_build_graph(job.data[-1]) return job def handleWorkData(self, packet): |