diff options
| author | Pedro Alvarez <pedro.alvarez@codethink.co.uk> | 2016-03-15 00:50:15 +0000 |
|---|---|---|
| committer | Pedro Alvarez <pedro.alvarez@codethink.co.uk> | 2016-03-27 11:53:02 +0000 |
| commit | 8341281cb8c65d4f9bf4098eefd6f765f317aebc (patch) | |
| tree | 64f529ed42d32cc16f3988a879f3e7ff5b9050d5 | |
| parent | 515b918e2681583a60bb870da070b054406a10d8 (diff) | |
| download | morph-8341281cb8c65d4f9bf4098eefd6f765f317aebc.tar.gz | |
Add notes
Change-Id: Ic14a6c7ad7233bb908d2f68c6673f09ad3c3cc60
| -rw-r--r-- | gear/client.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/gear/client.py b/gear/client.py index 8d35b03b..3cfe51bf 100644 --- a/gear/client.py +++ b/gear/client.py @@ -47,6 +47,8 @@ class theController(): print "Setting them as unbuilt" self._map_build_graph(self.artifact, set_initial_state) print "Setting them as unbuilt done" + # TODO: check cache before marking as started: + # http://stackoverflow.com/questions/9110593/asynchronous-requests-with-python-requests self.build_started = True def _map_build_graph(self, artifact, callback, components=[]): @@ -206,6 +208,9 @@ class BuilderClient(gear.Client): self.controller._mark_artifact_as_built(job.data[-1]) return job + # TODO: send different types of data? stdout, message...? + # same for workFail, to identify worker dissconection and build + # failures. def handleWorkData(self, packet): job = super(BuilderClient, self).handleWorkData(packet) print job.data[-1].strip() |