file_params)
return json.dumps(to_json_structure)
- def invoke(self, securitytoken=None, block=False, skip_if_running=False, invoke_pre_check_delay=3,
- invoke_block_delay=15, build_params=None, cause=None, files=None):
- assert isinstance(invoke_pre_check_delay, (int, float))
- assert isinstance(invoke_block_delay, (int, float))
+ def invoke(self, securitytoken=None, block=False, build_params=None, cause=None, files=None):
assert isinstance(block, bool)
- assert isinstance(skip_if_running, bool)
# Either copy the params dict or make a new one.
build_params = build_params and dict(
queue_url = response.headers['location']
qi = QueueItem(queue_url, self.jenkins)
+
+ if block:
+ qi.block_until_complete(delay=10)
return qi
def _buildid_for_type(self, buildtype):
self.jenkins.create_node(node_name)
job_name = 'create_%s' % random_string()
job = self.jenkins.create_job(job_name, LONG_RUNNING_JOB)
- ii = job.invoke(invoke_pre_check_delay=2)
- ii.block(until='not_queued')
+ qq = job.invoke(invoke_pre_check_delay=2)
+ qq.block_until_building()
if job.is_running() is False:
time.sleep(1)
if execs.is_idle() is False:
all_idle = False
self.assertNotEqual(execs.get_progress(), -1)
- self.assertEqual(execs.get_current_executable(), ii.get_build_number())
+ self.assertEqual(execs.get_current_executable(), qq.get_build_number())
self.assertEqual(execs.likely_stuck(), False)
self.assertEqual(all_idle, True, "Executor should have been triggered.")
def test_invoke_matrix_job(self):
job_name = 'create_%s' % random_string()
job = self.jenkins.create_job(job_name, MATRIX_JOB)
- job.invoke(block=True)
+ queueItem = job.invoke()
+ queueItem.block_until_complete()
build = job.get_last_build()