Actually terminates!

This commit is contained in:
Steven Robertson 2013-01-06 22:01:35 -08:00
parent a8f4e0007e
commit 57c29721eb

5
dist/client.py vendored
View File

@ -137,9 +137,10 @@ def main(addrs):
print 'Interrupt received, flushing' print 'Interrupt received, flushing'
while cli.taskmap: while cli.taskmap:
for k, v in cli.taskmap.items():
if not v.getters:
cli.taskmap.pop(k)
print 'Still waiting on %d tasks...' % len(cli.taskmap) print 'Still waiting on %d tasks...' % len(cli.taskmap)
for i in cli.taskmap.items():
print i
gevent.sleep(3) gevent.sleep(3)
if __name__ == "__main__": if __name__ == "__main__":