Package io.dapr.durabletask

Class TaskActivityExecutor

java.lang.Object

io.dapr.durabletask.TaskActivityExecutor

public final class TaskActivityExecutor
extends Object

Constructor Summary

Constructors

Constructor	Description
TaskActivityExecutor(HashMap<String,TaskActivityFactory> activityFactories, DataConverter dataConverter, Logger logger)	Constructor.

Method Summary

Modifier and Type	Method	Description
String	execute(String taskName, String input, String taskExecutionId, int taskId, String traceParent)	Executes an activity task.

Methods inherited from class java.lang.Object

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

Constructor Details

TaskActivityExecutor

public TaskActivityExecutor(HashMap<String,TaskActivityFactory> activityFactories,
 DataConverter dataConverter,
 Logger logger)

Constructor.

Parameters:

activityFactories - the activity factories to use for creating activities

dataConverter - the data converter to use for serializing and deserializing activity inputs and outputs

logger - the logger to use for logging

Method Details

execute

public String execute(String taskName,
 String input,
 String taskExecutionId,
 int taskId,
 String traceParent)
               throws Throwable

Executes an activity task.

Parameters:

taskName - the name of the activity task to execute

input - the serialized input payload for the activity task

taskExecutionId - Unique ID for the task execution.

taskId - Auto-incrementing ID for the task.

traceParent - The traceparent header value.

Returns:

the serialized output payload for the activity task, or null if the activity task returned null.

Throws:

Throwable - if an unhandled exception occurs during activity task execution.