Package com.tnsai.coordination.workflow

Class WorkflowContext

java.lang.Object

com.tnsai.coordination.workflow.WorkflowContext

public final class WorkflowContext
extends Object

Shared context passed through workflow steps. Thread-safe for concurrent DAG execution.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	WorkflowContext.StepResult	Result of a single workflow step execution.

Constructor Summary

Constructors

Constructor	Description
WorkflowContext(String workflowId)
WorkflowContext(String workflowId, Map<String,Object> initialData)

Method Summary

Modifier and Type	Method	Description
<T> T	get(String key)
Map<String,WorkflowContext.StepResult>	getAllStepResults()
Map<String,Object>	getData()
<T> T	getOrDefault(String key, T defaultValue)
WorkflowContext.StepResult	getStepResult(String stepId)	Gets the result of a previously completed step.
String	getWorkflowId()
boolean	has(String key)
void	put(String key, Object value)
void	recordStepResult(String stepId, WorkflowContext.StepResult result)	Records the result of a completed step.

Methods inherited from class java.lang.Object

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

Constructor Details

WorkflowContext

public WorkflowContext(String workflowId)

WorkflowContext

public WorkflowContext(String workflowId,
 Map<String,Object> initialData)

Method Details

getWorkflowId

public String getWorkflowId()

put

public void put(String key,
 Object value)

get

public <T> T get(String key)

getOrDefault

public <T> T getOrDefault(String key,
 T defaultValue)

has

public boolean has(String key)

getData

public Map<String,Object> getData()

recordStepResult

public void recordStepResult(String stepId,
 WorkflowContext.StepResult result)

Records the result of a completed step.

getStepResult

public WorkflowContext.StepResult getStepResult(String stepId)

Gets the result of a previously completed step.

getAllStepResults

public Map<String,WorkflowContext.StepResult> getAllStepResults()