kiara.processing.processor

ModuleProcessor

wait_for(self, *job_ids, *, sync_outputs=True)

Wait for the jobs with the specified ids, also optionally sync their outputs with the pipeline value state.

Source code in kiara/processing/processor.py

def wait_for(self, *job_ids: str, sync_outputs: bool = True):
    """Wait for the jobs with the specified ids, also optionally sync their outputs with the pipeline value state."""

    self._wait_for(*job_ids)

    for job_id in job_ids:
        job = self.get_job_details(job_id)
        if job is None:
            raise Exception(f"Can't find job with id: {job_id}")
        if job.status == JobStatus.SUCCESS:
            job.job_log.percent_finished = 100

    if sync_outputs:
        self.sync_outputs(*job_ids)