Permalink
Browse files

Merge pull request #341 from irskep/intermittent_pooling_test_failure…

…_331

Broke test_dont_join_full_job_flow into two tests
  • Loading branch information...
2 parents e3bdeaa + 48c9747 commit 6c3d045333ed631dcaf85bd4b312e5811bf56c63 David Marin committed Jan 21, 2012
Showing with 12 additions and 1 deletion.
  1. +12 −1 tests/test_emr.py
View
@@ -2289,7 +2289,18 @@ def test_dont_join_full_job_flow(self):
'-c', self.mrjob_conf_path],
job_class=MRTwoStepJob)
- # but a one-step job should fit
+ def test_join_almost_full_job_flow(self):
+ dummy_runner, job_flow_id = self.make_pooled_job_flow('pool1')
+
+ # fill the job flow
+ self.mock_emr_job_flows[job_flow_id].steps = 255 * [
+ MockEmrObject(
+ state='COMPLETED',
+ name='dummy',
+ actiononfailure='CANCEL_AND_WAIT',
+ args=[])]
+
+ # a one-step job should fit
self.assertJoins(job_flow_id, [
'-r', 'emr', '-v', '--pool-emr-job-flows',
'--pool-name', 'pool1',

0 comments on commit 6c3d045

Please sign in to comment.