|
|
|
@@ -381,7 +381,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
@@ -410,7 +410,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template, job_type='check')
|
|
|
|
job = self.create_test_job(job_template=job_template, job_type='check')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
@@ -438,7 +438,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
@@ -466,7 +466,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
@@ -590,7 +590,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template, job_type='check')
|
|
|
|
job = self.create_test_job(job_template=job_template, job_type='check')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
@@ -630,7 +630,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
# Calling cancel before start has no effect.
|
|
|
|
# Calling cancel before start has no effect.
|
|
|
|
self.assertFalse(job.cancel())
|
|
|
|
self.assertFalse(job.cancel())
|
|
|
|
self.assertEqual(job.cancel_flag, False)
|
|
|
|
self.assertEqual(job.cancel_flag, False)
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.build_args_callback = self._cancel_job_callback
|
|
|
|
self.build_args_callback = self._cancel_job_callback
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
@@ -653,7 +653,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
extra_vars='foo=1')
|
|
|
|
extra_vars='foo=1')
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
@@ -669,7 +669,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template(limit='bad.example.com')
|
|
|
|
job_template = self.create_test_job_template(limit='bad.example.com')
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
@@ -683,7 +683,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
@@ -697,8 +697,8 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertTrue(job.get_passwords_needed_to_start())
|
|
|
|
self.assertTrue(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue('ssh_password' in job.get_passwords_needed_to_start())
|
|
|
|
self.assertTrue('ssh_password' in job.passwords_needed_to_start)
|
|
|
|
self.assertFalse(job.start())
|
|
|
|
self.assertFalse(job.start())
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertTrue(job.start(ssh_password='sshpass'))
|
|
|
|
self.assertTrue(job.start(ssh_password='sshpass'))
|
|
|
|
@@ -714,7 +714,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
@@ -730,8 +730,8 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertTrue(job.get_passwords_needed_to_start())
|
|
|
|
self.assertTrue(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue('sudo_password' in job.get_passwords_needed_to_start())
|
|
|
|
self.assertTrue('sudo_password' in job.passwords_needed_to_start)
|
|
|
|
self.assertFalse(job.start())
|
|
|
|
self.assertFalse(job.start())
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertTrue(job.start(sudo_password='sudopass'))
|
|
|
|
self.assertTrue(job.start(sudo_password='sudopass'))
|
|
|
|
@@ -748,7 +748,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
@@ -762,7 +762,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
@@ -777,7 +777,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
@@ -792,8 +792,8 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertTrue(job.get_passwords_needed_to_start())
|
|
|
|
self.assertTrue(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue('ssh_key_unlock' in job.get_passwords_needed_to_start())
|
|
|
|
self.assertTrue('ssh_key_unlock' in job.passwords_needed_to_start)
|
|
|
|
self.assertFalse(job.start())
|
|
|
|
self.assertFalse(job.start())
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertTrue(job.start(ssh_key_unlock=TEST_SSH_KEY_DATA_UNLOCK))
|
|
|
|
self.assertTrue(job.start(ssh_key_unlock=TEST_SSH_KEY_DATA_UNLOCK))
|
|
|
|
@@ -808,7 +808,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
@@ -836,7 +836,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
@@ -864,7 +864,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
@@ -893,7 +893,7 @@ class RunJobTest(BaseCeleryTest):
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job_template = self.create_test_job_template()
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
job = self.create_test_job(job_template=job_template)
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertEqual(job.status, 'new')
|
|
|
|
self.assertFalse(job.get_passwords_needed_to_start())
|
|
|
|
self.assertFalse(job.passwords_needed_to_start)
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertTrue(job.start())
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
self.assertEqual(job.status, 'pending')
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
job = Job.objects.get(pk=job.pk)
|
|
|
|
|