SINGA-266 Add Rafiki python toolkits - fix bug, remove debug comments
Project: http://git-wip-us.apache.org/repos/asf/incubator-singa/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-singa/commit/9eabb956 Tree: http://git-wip-us.apache.org/repos/asf/incubator-singa/tree/9eabb956 Diff: http://git-wip-us.apache.org/repos/asf/incubator-singa/diff/9eabb956 Branch: refs/heads/master Commit: 9eabb956375f2ac31f688f16c221b6328914afc6 Parents: f536975 Author: aaronwwf <[email protected]> Authored: Thu Oct 20 10:53:57 2016 +0800 Committer: aaronwwf <[email protected]> Committed: Thu Oct 20 10:53:57 2016 +0800 ---------------------------------------------------------------------- python/rafiki/agent.py | 5 ----- 1 file changed, 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-singa/blob/9eabb956/python/rafiki/agent.py ---------------------------------------------------------------------- diff --git a/python/rafiki/agent.py b/python/rafiki/agent.py index f8d4b51..d31c9da 100644 --- a/python/rafiki/agent.py +++ b/python/rafiki/agent.py @@ -104,21 +104,16 @@ def getDataFromInfoQueue(need_return=False): global info_queue_, data_ if not need_return: while not info_queue_.empty(): - info_queue_.top() msg,d = info_queue_.get() data_.append(d) else: while True: # loop until get answer - print 'test' while not info_queue_.empty(): - print 'test2' msg,d = info_queue_.get() if msg.is_info(): - print 'test3' data_.append(d) else: return msg,d - print 'test4' time.sleep(0.01)
