qcg.pilotjob.resume module¶

class qcg.pilotjob.resume.StateTracker(path)¶

Bases: object

This class traces incoming requests and job status changes to record current state which can be used to resume prematurely interrupted execution of QCG-Pilot job service.

Initialize state tracker.

reqs_file¶

Type:	str

finished_file¶

Type:	str

Parameters:	path - path to the directory where tracker files will be saved, if None, the current working directory (*) – will be used

static resume(path, manager, progress=False)¶

Resume interrupted task iterations execution.

Parameters:	path () – manager* (*) –

new_submited_jobs(jobs)¶

Register new submit job request. The new request is appended to all previous requests in the self.reqs_file file.

Parameters:	jobs (*) –

job_finished(job, iteration)¶

Register finished job status change. In case of final task (iterations) status change (SUCCEED, FAILED, CANCELED, OMITTED) task identifier with the final state is saved to the self.finished_file file.

Parameters:	job () – iteration* (*) –

all_jobs_finished()¶: All submited job’s finished successfully. The tracker files should be removed.