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

Class JobFailureAndKillHandlerLogicTask

java.lang.Object

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

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

All Implemented Interfaces:

WorkflowTask

public class JobFailureAndKillHandlerLogicTask
extends GenieBaseTask

This class is responsible for adding the kill handling logic to run.sh.

Since:

3.0.0

Constructor Summary

Constructors

Constructor and Description
JobFailureAndKillHandlerLogicTask(@NotNull io.micrometer.core.instrument.MeterRegistry registry) Constructor.

Method Summary

Modifier and Type	Method and Description
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

JobFailureAndKillHandlerLogicTask

public JobFailureAndKillHandlerLogicTask(@NotNull
                                         @NotNull io.micrometer.core.instrument.MeterRegistry registry)

Constructor.

Parameters:

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.