diff options
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): |