Crate rs_dagcuter 

Structs

Dag

DAG (Directed Acyclic Graph) Executor for task scheduling Manages task dependencies and executes them in topological order Uses Kahn’s algorithm for topological sorting with concurrent execution

RetryPolicy

Configuration for exponential backoff retry mechanism Implements intelligent retry logic with configurable parameters

Enums

Error

Comprehensive error types for task execution system Uses thiserror for automatic error trait implementations

Traits

Task

Core trait defining task behavior and lifecycle All tasks must implement this trait to be executable by the DAG Provides hooks for custom pre/post processing logic

Type Aliases

BoxTask

Type alias for thread-safe task references Arc enables sharing tasks across threads safely

TaskInput

Type alias for task input parameters Provides flexibility for passing various data types between tasks

TaskResult

Type alias for task execution results Uses HashMap to allow flexible key-value output data