Enum DagExecutionResponse 

pub enum DagExecutionResponse<Compact, IdType> {
    EntryFanOut {
        node_task_ids: HashMap<NodeIndex, TaskId<IdType>>,
    },
    FanOut {
        response: Compact,
        node_task_ids: HashMap<NodeIndex, TaskId<IdType>>,
    },
    EnqueuedNext {
        result: Compact,
    },
    WaitingForDependencies {
        pending_dependencies: HashMap<NodeIndex, TaskId<IdType>>,
    },
    Complete {
        result: Compact,
    },
}

Response from DAG execution step

Variants

EntryFanOut

Entry nodes have been fanned out

Fields

node_task_ids: HashMap<NodeIndex, TaskId<IdType>>

Map of node indices to their task IDs

FanOut

Next tasks have been fanned out

Fields

response: Compact

Result of the current task

node_task_ids: HashMap<NodeIndex, TaskId<IdType>>

Map of node indices to their task IDs

EnqueuedNext

Next task has been enqueued

Fields

result: Compact

Result of the current task

WaitingForDependencies

Waiting for dependencies to complete

Fields

pending_dependencies: HashMap<NodeIndex, TaskId<IdType>>

Map of pending dependency node indices to their task IDs

Complete

DAG execution is complete

Fields

result: Compact

Result of the final task

Trait Implementations

impl<Compact: Clone, IdType: Clone> Clone for DagExecutionResponse<Compact, IdType>

fn clone(&self) -> DagExecutionResponse<Compact, IdType>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Compact: Debug, IdType: Debug> Debug for DagExecutionResponse<Compact, IdType>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de, Compact, IdType> Deserialize<'de> for DagExecutionResponse<Compact, IdType>

where Compact: Deserialize<'de>, IdType: Deserialize<'de>,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<Compact: Eq, IdType: Eq> Eq for DagExecutionResponse<Compact, IdType>

impl<Compact: PartialEq, IdType: PartialEq> PartialEq for DagExecutionResponse<Compact, IdType>

fn eq(&self, other: &DagExecutionResponse<Compact, IdType>) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl<Compact, IdType> Serialize for DagExecutionResponse<Compact, IdType>

where Compact: Serialize, IdType: Serialize,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<Compact: PartialEq, IdType: PartialEq> StructuralPartialEq for DagExecutionResponse<Compact, IdType>