Changeset [5fd6ae167d5f19dc1d0d88d45d1e1229bec4b927] by Shayan Pooya
May 12th, 2014 @ 12:40 PM
worker: fix the input termination condition.
Disco is done sending inputs to the worker when it sends the
worker
the "done" message with the input. Otherwise, the worker should
keep requesting inputs.
https://github.com/discoproject/disco/commit/5fd6ae167d5f19dc1d0d88...
Committed by Shayan Pooya
- M lib/disco/worker/__init__.py
Create new ticket
Create your profile
Help contribute to this project by taking a few moments to create your personal profile. Create your profile ยป
Disco is an open-source implementation of the Map-Reduce framework for distributed computing. As the original framework, Disco supports parallel computations over large data sets on unreliable cluster of computers.