com.netflix.genie.web.services.impl

Class JobLaunchServiceImpl

java.lang.Object

com.netflix.genie.web.services.impl.JobLaunchServiceImpl

All Implemented Interfaces:

JobLaunchService

public class JobLaunchServiceImpl
extends java.lang.Object
implements JobLaunchService

Default implementation of the JobLaunchService.

Since:

4.0.0

Constructor Summary

Constructors

Constructor and Description
JobLaunchServiceImpl(JobPersistenceService jobPersistenceService, JobResolverService jobResolverService, AgentLauncher agentLauncher, io.micrometer.core.instrument.MeterRegistry registry) Constructor.

Method Summary

Modifier and Type	Method and Description
java.lang.String	launchJob(@Valid JobSubmission jobSubmission) Launches a job on behalf of the user.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JobLaunchServiceImpl

public JobLaunchServiceImpl(JobPersistenceService jobPersistenceService,
                            JobResolverService jobResolverService,
                            AgentLauncher agentLauncher,
                            io.micrometer.core.instrument.MeterRegistry registry)

Constructor.

Parameters:

jobPersistenceService - JobPersistenceService implementation to save job data

jobResolverService - JobResolverService implementation used to resolve job details

agentLauncher - AgentLauncher implementation to launch agents

registry - MeterRegistry metrics repository

Method Detail

launchJob

@Nonnull
public java.lang.String launchJob(@Valid
                                           @Valid JobSubmission jobSubmission)
                                    throws AgentLaunchException,
                                           GenieJobResolutionException,
                                           IdAlreadyExistsException,
                                           SaveAttachmentException

Launches a job on behalf of the user.

Given the information submitted to Genie this service will attempt to run the job which will include: - Saving the job submission information including attachments - Resolving the resources needed to run the job and persisting them - Launching the agent

Specified by:

launchJob in interface JobLaunchService

Parameters:

jobSubmission - The payload of metadata and resources making up all the information needed to launch a job

Returns:

The id of the job. Upon return the job will at least be in JobStatus.ACCEPTED state

Throws:

AgentLaunchException - If the system was unable to launch an agent to handle job execution

GenieJobResolutionException - If the job, based on user input and current system state, can't be successfully resolved for whatever reason

IdAlreadyExistsException - If the unique identifier for the job conflicts with an already existing job

SaveAttachmentException - When a job is submitted with attachments but there is an error saving them