qunicorn_core.core.jobmanager package

Submodules

qunicorn_core.core.jobmanager.jobmanager_service module

qunicorn_core.core.jobmanager.jobmanager_service.cancel_job_by_id(job_id)

cancel job execution

qunicorn_core.core.jobmanager.jobmanager_service.check_registered_pilots()

get all registered pilots for computing the schedule

qunicorn_core.core.jobmanager.jobmanager_service.create_and_run_job(job_request_dto: JobRequestDto, asynchronous: bool = False) → SimpleJobDto

First creates a job to let it run afterwards on a pilot

qunicorn_core.core.jobmanager.jobmanager_service.delete_job_data_by_id(job_id) → JobResponseDto

delete job data from db

qunicorn_core.core.jobmanager.jobmanager_service.get_all_jobs() → list[qunicorn_core.api.api_models.job_dtos.SimpleJobDto]

get all jobs from the db

qunicorn_core.core.jobmanager.jobmanager_service.get_job(job_id: int) → JobResponseDto

Gets the job from the database service with its id

qunicorn_core.core.jobmanager.jobmanager_service.pause_job_by_id(job_id)

pause job execution

qunicorn_core.core.jobmanager.jobmanager_service.re_run_job_by_id(job_id: int, token: str) → SimpleJobDto

Get job from DB, Save it as new job and run it with the new id

qunicorn_core.core.jobmanager.jobmanager_service.run_job_by_id(job_id: int, job_execution_dto: JobExecutePythonFileDto, asynchronous: bool = False) → SimpleJobDto

Get uploaded job from DB, and run it on a provider

qunicorn_core.core.jobmanager.jobmanager_service.schedule_jobs()

start the scheduling

qunicorn_core.core.jobmanager.jobmanager_service.send_job_to_pilot()

send job to pilot for execution after it is scheduled

Module contents