Class ScheduleTriggerExecutor

java.lang.Object

ai.nervemind.app.executor.ScheduleTriggerExecutor

All Implemented Interfaces:

NodeExecutor

@Component
public class ScheduleTriggerExecutor
extends Object
implements NodeExecutor

Executor for the "scheduleTrigger" node type - starts workflow execution on a schedule.

Enables time-based automated workflow execution using cron expressions. The actual scheduling is managed by SchedulerService; this executor is invoked when the scheduled time arrives.

Node Parameters

Schedule trigger configuration parameters

Parameter	Type	Default	Description
cronExpression	String	""	Cron expression for scheduling
timezone	String	"UTC"	Timezone for schedule evaluation

Cron Expression Examples

• 0 0 * * * - Daily at midnight
• 0 9 * * 1-5 - Weekdays at 9 AM
• 0/30 * * * * - Every 30 minutes
• 0 8 1 * * - Monthly on the 1st at 8 AM

Output Data

Output keys added by this executor

Key	Type	Description
triggeredAt	String	ISO timestamp when execution started
triggerType	String	Always "schedule" for this trigger
cronExpression	String	The cron expression that fired
timezone	String	The configured timezone
scheduledTime	String	The scheduled time that triggered this run

See Also:

• For on-demand execution
• For HTTP request-triggered execution
• The service that manages schedules

Constructor Summary

Constructors

Constructor	Description
ScheduleTriggerExecutor()	Default constructor.

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	execute(ai.nervemind.common.domain.Node node, Map<String,Object> input, ExecutionService.ExecutionContext context)	Executes the business logic for this node type.
String	getNodeType()	Unique identifier for the node type this executor handles.

Methods inherited from class Object

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

Constructor Details

ScheduleTriggerExecutor

public ScheduleTriggerExecutor()

Default constructor.

Method Details

execute

public Map<String,Object> execute(ai.nervemind.common.domain.Node node,
 Map<String,Object> input,
 ExecutionService.ExecutionContext context)

Description copied from interface: NodeExecutor

Executes the business logic for this node type.

Specified by:

execute in interface NodeExecutor

Parameters:

node - The node definition containing parameters and configuration. Use Node.parameters() to access user settings.

input - Combined output from all upstream nodes that connected to this node. For simple flows, this contains the direct predecessor's output. For merge nodes, it contains combined data.

context - Verification context providing access to workflow-scoped services, logger, and execution metadata.

Returns:

A Map containing the results of this node's execution. Keys in this map become available variables for downstream nodes.
Note: Returning null is treated as an empty map.

getNodeType

public String getNodeType()

Description copied from interface: NodeExecutor

Unique identifier for the node type this executor handles. This must match the 'type' field in the JSON definition of the node.

Specified by:

getNodeType in interface NodeExecutor

Returns:

The unique type string (e.g., "httpRequest", "llmChat").