com.netflix.genie.web.jobs.workflow.impl

Class JobKickoffTask

java.lang.Object

com.netflix.genie.web.jobs.workflow.impl.GenieBaseTask

com.netflix.genie.web.jobs.workflow.impl.JobKickoffTask

All Implemented Interfaces:

WorkflowTask

public class JobKickoffTask
extends GenieBaseTask

Implementation of the workflow task for processing job information for genie mode.

Since:

3.0.0

Constructor Summary

Constructors

Constructor and Description
JobKickoffTask(boolean runAsUserEnabled, boolean userCreationEnabled, @NotNull org.apache.commons.exec.Executor executor, @NotNull java.lang.String hostname, @NotNull io.micrometer.core.instrument.MeterRegistry registry) Constructor.

Method Summary

Modifier and Type	Method and Description
protected void	changeOwnershipOfDirectory(java.lang.String dir, java.lang.String user) Method to change the ownership of a directory.
protected void	createUser(java.lang.String user, java.lang.String group) Create user on the system.
void	executeTask(@NotNull java.util.Map<java.lang.String,java.lang.Object> context) Execute the task.

Methods inherited from class com.netflix.genie.web.jobs.workflow.impl.GenieBaseTask

buildLocalFilePath

Methods inherited from class java.lang.Object

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

Constructor Detail

JobKickoffTask

public JobKickoffTask(boolean runAsUserEnabled,
                      boolean userCreationEnabled,
                      @NotNull
                      @NotNull org.apache.commons.exec.Executor executor,
                      @NotNull
                      @NotNull java.lang.String hostname,
                      @NotNull
                      @NotNull io.micrometer.core.instrument.MeterRegistry registry)

Constructor.

Parameters:

runAsUserEnabled - Flag that tells if job should be run as user specified in the request

userCreationEnabled - Flag that tells if the user specified should be created

executor - An executor object used to run jobs

hostname - Hostname for the node the job is running on

registry - The metrics registry to use

Method Detail

executeTask

public void executeTask(@NotNull
                        @NotNull java.util.Map<java.lang.String,java.lang.Object> context)
                 throws GenieException,
                        java.io.IOException

Execute the task.

Parameters:

context - Information needed to execute the task.

Throws:

GenieException - if there is an error.

java.io.IOException - if there is a problem writing to the disk.

createUser

protected void createUser(java.lang.String user,
                          java.lang.String group)
                   throws GenieException

Create user on the system. Synchronized to prevent multiple threads from trying to create user at the same time.

Parameters:

user - user id

group - group id

Throws:

GenieException - If there is any problem.

changeOwnershipOfDirectory

protected void changeOwnershipOfDirectory(java.lang.String dir,
                                          java.lang.String user)
                                   throws GenieException

Method to change the ownership of a directory.

Parameters:

dir - The directory to change the ownership of.

user - Userid of the user.

Throws:

GenieException - If there is a problem.