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 = True) → 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)

delete job data

qunicorn_core.core.jobmanager.jobmanager_service.get_all_jobs()

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.run_job_by_id(job_id: int) → SimpleJobDto

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

qunicorn_core.core.jobmanager.jobmanager_service.save_job_to_storage()

store job for later use

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