qunicorn_core.core.job_service module

qunicorn_core.core.job_service.cancel_job_by_id(job_id, token: str | None, user_id: str | None = None) → SimpleJobDto

cancel job execution

qunicorn_core.core.job_service.create_and_run_job(job_request_dto: JobRequestDto, is_asynchronous: bool = False, user_id: str | None = None) → SimpleJobDto

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

qunicorn_core.core.job_service.delete_job_data_by_id(job_id, user_id: str | None)

delete job data from db

qunicorn_core.core.job_service.delete_jobs_by_deployment_id(deployment_id, user_id: str | None = None) → list[SimpleJobDto]

delete all jobs of a deployment that the user is authorized to with the id deployment_id

qunicorn_core.core.job_service.get_all_jobs(user_id: str | None, status: str | None = None, deployment: int | None = None, device: int | None = None, page: int = 1, item_count: int = 100) → list[SimpleJobDto]

get all jobs from the db

qunicorn_core.core.job_service.get_job_by_id(job_id: int, user_id: str | None) → JobResponseDto

Gets the job from the database service with its id

qunicorn_core.core.job_service.get_job_queue_items(user_id: str | None) → dict

Get the latest running job and all latest ready jobs

qunicorn_core.core.job_service.get_job_result_by_id(result_id: int, job_id: int, user_id: str | None) → ResultDto

qunicorn_core.core.job_service.get_jobs_by_deployment_id(deployment_id, user_id: str | None = None) → list[SimpleJobDto]

get all jobs of a deployment that the user is authorized to with the id deployment_id

qunicorn_core.core.job_service.get_latest_ready_jobs(all_jobs: Sequence[JobDataclass]) → list[SimpleJobDto]

Get all latest jobs with state ready until reaching the first finished job

qunicorn_core.core.job_service.get_latest_running_job(all_jobs: Sequence[JobDataclass]) → SimpleJobDto | None

Get the latest job with state running, check until reaching the first finished job

qunicorn_core.core.job_service.re_run_job_by_id(job_id: int, token: str | None, user_id: str | None = None) → SimpleJobDto

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

qunicorn_core.core.job_service.run_job_by_id(job_id: int, job_exec_dto: JobExecutePythonFileDto, asyn: bool = False, user_id: str | None = None) → SimpleJobDto

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

qunicorn_core.core.job_service.run_job_with_celery(job: JobDataclass, is_asynchronous: bool, token: str | None = None)

Serialize the job and run it with celery