Struct PregelExecutableTask 

pub struct PregelExecutableTask {
    pub name: String,
    pub input: Value,
    pub proc: Arc<dyn Runnable>,
    pub writes: Vec<(String, Value)>,
    pub config: RunnableConfig,
    pub triggers: Vec<String>,
    pub id: String,
}

An executable task with its runnable and write buffer.

Fields

name: String

Name of the node.

input: Value

Input value.

proc: Arc<dyn Runnable>

The runnable to execute (node logic + writers).

writes: Vec<(String, Value)>

Write buffer: (channel, value) pairs collected during execution.

config: RunnableConfig

Task configuration (with CONFIG_KEY_SEND, CONFIG_KEY_READ, etc.).

triggers: Vec<String>

Channels that triggered this task.

id: String

Unique task ID.