Changeset [856a6561935e2d72cca86425a57e2680b081e720] by Shayan Pooya
February 21st, 2014 @ 10:19 AM
Set the job variable before running tests.
If a test is interrupted, it is checked to see if they have a
'job'
associated with them and if so the job is purged. However if a
test
does something like:
self.job = Job().wait() the interruption will occur while it is
waiting for the results and
the self.job is not set at this time, so it will not be purged.
https://github.com/discoproject/disco/commit/856a6561935e2d72cca864...
Committed by Shayan Pooya
- M tests/test_async.py
- M tests/test_chain.py
- M tests/test_examples.py
- M tests/test_input.py
- M tests/test_save.py
- M tests/test_schemes.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.