job runner¶
-
class
JobRunnerBase
¶ Bases:
abc.ABC
Baseclass 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.Enum
Job 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
-