job runner¶
-
class
JobRunnerBase¶ Bases:
abc.ABCBaseclass for all job runners so that they can be used together with the MLRepo
-
add(job_name, job_version, user)¶ [summary]
-
get_info(job_name, job_version)¶ [summary]
-
-
class
JobState¶ Bases:
enum.EnumJob states
-
class
SQLiteJobRunner(sqlite_db_name, repo, sleep=1, steps_to_heartbeat=30)¶ Bases:
pailab.job_runner.job_runner.JobRunnerBase-
add(job_name, job_version, user)¶ [summary]
-
close_connection()¶ Closes the database connection
-
get_info(job_name, job_version)¶ [summary]
-
get_waiting_jobs()¶ Return list of open jobs
Returns: list containing tuples of job names and versions of the jobs currently waiting Return type: list of tuples
-
-
class
SimpleJobRunner(repo, throw_job_error=False)¶ Bases:
pailab.job_runner.job_runner.JobRunnerBase-
add(job_name, job_version, user)¶ [summary]
-
get_info(job_name, job_version)¶ [summary]
-
get_waiting_jobs()¶ Return list of open jobs
Returns: empty list because by construction, this JobRunner can only return something if the jobs have been finished
-