diff options
Diffstat (limited to 'taskflow/tests/unit/jobs/test_redis_job.py')
| -rw-r--r-- | taskflow/tests/unit/jobs/test_redis_job.py | 23 |
1 files changed, 23 insertions, 0 deletions
diff --git a/taskflow/tests/unit/jobs/test_redis_job.py b/taskflow/tests/unit/jobs/test_redis_job.py index f988788..2bde77f 100644 --- a/taskflow/tests/unit/jobs/test_redis_job.py +++ b/taskflow/tests/unit/jobs/test_redis_job.py @@ -20,6 +20,7 @@ from oslo_utils import uuidutils import six import testtools +from taskflow import exceptions as excp from taskflow.jobs.backends import impl_redis from taskflow import states from taskflow import test @@ -76,6 +77,28 @@ class RedisJobboardTest(test.TestCase, base.BoardTestMixin): possible_jobs = list(self.board.iterjobs(only_unclaimed=True)) self.assertEqual(1, len(possible_jobs)) + def test_posting_claim_same_owner(self): + with base.connect_close(self.board): + with self.flush(self.client): + self.board.post('test', p_utils.temporary_log_book()) + + self.assertEqual(1, self.board.job_count) + possible_jobs = list(self.board.iterjobs(only_unclaimed=True)) + self.assertEqual(1, len(possible_jobs)) + j = possible_jobs[0] + self.assertEqual(states.UNCLAIMED, j.state) + + with self.flush(self.client): + self.board.claim(j, self.board.name) + + possible_jobs = list(self.board.iterjobs()) + self.assertEqual(1, len(possible_jobs)) + with self.flush(self.client): + self.assertRaises(excp.UnclaimableJob, self.board.claim, + possible_jobs[0], self.board.name) + possible_jobs = list(self.board.iterjobs(only_unclaimed=True)) + self.assertEqual(0, len(possible_jobs)) + def setUp(self): super(RedisJobboardTest, self).setUp() self.client, self.board = self.create_board() |