com.netflix.genie.agent.execution.services

Interface LaunchJobService

All Superinterfaces:

org.springframework.context.ApplicationListener<KillService.KillEvent>, java.util.EventListener

public interface LaunchJobService
extends org.springframework.context.ApplicationListener<KillService.KillEvent>

Service that launches the job process.

Since:

4.0.0

Method Summary

Modifier and Type	Method and Description
void	kill() Terminate job process execution (if still running) or prevent it from launching (if not launched yet).
void	launchProcess(java.io.File jobDirectory, java.util.Map<java.lang.String,java.lang.String> environmentVariables, java.util.List<java.lang.String> commandLine, boolean interactive) Launch the job process (unless launch was aborted by previous a kill call).
JobStatus	waitFor() Wait indefinitely for the job process to terminate.

Methods inherited from interface org.springframework.context.ApplicationListener

onApplicationEvent

Method Detail

launchProcess

void launchProcess(java.io.File jobDirectory,
                   java.util.Map<java.lang.String,java.lang.String> environmentVariables,
                   java.util.List<java.lang.String> commandLine,
                   boolean interactive)
            throws JobLaunchException

Launch the job process (unless launch was aborted by previous a kill call).

Parameters:

jobDirectory - Job directory

environmentVariables - additional environment variables (to merge on top of inherited environment)

commandLine - command-line executable and arguments

interactive - launch in interactive mode (inherit I/O) or batch (no input, write outputs to files)

Throws:

JobLaunchException - if the job process failed to launch

kill

void kill()

Terminate job process execution (if still running) or prevent it from launching (if not launched yet). Optionally sends SIGINT to the process (unnecessary under certain circumstances. For example, CTRL-C in a terminal session, is already received by the job process, issuing a second one is unneeded).

waitFor

JobStatus waitFor()
           throws java.lang.InterruptedException

Wait indefinitely for the job process to terminate.

Returns:

KILLED, SUCCESSFUL, or FAILED

Throws:

java.lang.IllegalStateException - if the process was not launched

java.lang.InterruptedException - if the calling thread is interrupted while waiting