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

Class JobTask

java.lang.Object

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

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

All Implemented Interfaces:

WorkflowTask

public class JobTask
extends GenieBaseTask

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

Since:

3.0.0

Constructor Summary

Constructors

Constructor and Description
JobTask(@NotNull AttachmentService attachmentService, @NotNull io.micrometer.core.instrument.MeterRegistry registry, @NotNull GenieFileTransferService fts) 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

JobTask

public JobTask(@NotNull
               @NotNull AttachmentService attachmentService,
               @NotNull
               @NotNull io.micrometer.core.instrument.MeterRegistry registry,
               @NotNull
               @NotNull GenieFileTransferService fts)

Constructor.

Parameters:

attachmentService - An implementation of the Attachment Service

registry - The metrics registry to use

fts - File transfer service

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.