qunicorn_core.core package

Subpackages

Submodules

qunicorn_core.core.deployment_service module

qunicorn_core.core.deployment_service.create_deployment(deployment_dto: DeploymentRequestDto) DeploymentDto

Create a deployment and save it in the database

qunicorn_core.core.deployment_service.delete_deployment(id: int) DeploymentDto

Remove one deployment by id

qunicorn_core.core.deployment_service.get_all_deployments() list[DeploymentDto]

Gets all deployments

qunicorn_core.core.deployment_service.get_deployment_by_id(id: int) DeploymentDataclass

Gets one deployment

qunicorn_core.core.deployment_service.update_deployment(deployment_dto: DeploymentRequestDto, deployment_id: int) DeploymentDto

Updates one deployment

qunicorn_core.core.device_service module

qunicorn_core.core.device_service.check_if_device_available(device_id: int, token: str) dict

Checks if the backend is available at the provider currently

qunicorn_core.core.device_service.get_all_devices() list[SimpleDeviceDto]

Gets all Devices from the DB and maps them

qunicorn_core.core.device_service.get_device_by_id(device_id: int) DeviceDto

Gets a Device from the DB by its ID and maps it

qunicorn_core.core.device_service.get_device_data_from_provider(device_id: int, token: str) dict

Get the device from the provider and return the configuration as dict

qunicorn_core.core.device_service.update_devices(device_request: DeviceRequestDto)

Update all backends for the provider from device_request

qunicorn_core.core.job_manager_service module

qunicorn_core.core.job_manager_service.cancel_job(job_core_dto)

cancel job execution

qunicorn_core.core.job_service module

qunicorn_core.core.job_service.cancel_job_by_id(job_id, token)

cancel job execution

qunicorn_core.core.job_service.check_registered_pilots()

get all registered pilots for computing the schedule

qunicorn_core.core.job_service.create_and_run_job(job_request_dto: JobRequestDto, is_asynchronous: bool = False) 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) JobResponseDto

delete job data from db

qunicorn_core.core.job_service.delete_jobs_by_deployment_id(deployment_id) list[JobResponseDto]

delete all jobs with the id deployment_id

qunicorn_core.core.job_service.get_all_jobs() list[SimpleJobDto]

get all jobs from the db

qunicorn_core.core.job_service.get_job_by_id(job_id: int) JobResponseDto

Gets the job from the database service with its id

qunicorn_core.core.job_service.get_jobs_by_deployment_id(deployment_id) list[JobResponseDto]

get all jobs with the id deployment_id

qunicorn_core.core.job_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.job_service.run_job_by_id(job_id: int, job_exec_dto: JobExecutePythonFileDto, asyn: bool = False) SimpleJobDto

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

qunicorn_core.core.job_service.run_job_with_celery(job_core_dto: JobCoreDto, is_asynchronous: bool)
qunicorn_core.core.job_service.schedule_jobs()

start the scheduling

qunicorn_core.core.job_service.send_job_to_pilot()

send job to pilot for execution after it is scheduled

qunicorn_core.core.provider_service module

qunicorn_core.core.provider_service.get_all_providers() list[ProviderDto]

Gets all Providers from the DB and maps them

qunicorn_core.core.provider_service.get_provider_by_id(provider_id: int) ProviderDto

Gets a Provider from the DB by its ID and maps it

qunicorn_core.core.user_service module

qunicorn_core.core.user_service.get_all_users() list[UserDto]

Gets all Users from the DB and maps them

qunicorn_core.core.user_service.get_user_by_id(user_id: int) UserDto

Gets a User from the DB by its ID and maps it

Module contents