Skip to main content
The core package provides a flexible framework for defining and executing workflows. It implements a DAG‑based system where tasks move through processing nodes, and each node updates a shared task context.

​
Package Structure

The core package consists of the following components: Core Components:
  • Nodes - Node implementations for workflow processing
  • Schema - Schema definitions for workflow configuration
  • Task Context - Task context definitions for state management
  • Validation - Workflow validation utilities
  • Workflow - Workflow orchestration and execution
app/core/
├── nodes/               # Node implementations for workflow processing
├── schema.py            # Schema definitions for workflow configuration
├── task.py              # Task context definitions
├── validate.py          # Workflow validation utilities
└── workflow.py          # Workflow orchestration

​
Key Features

Key Features:
  • Workflow orchestration: Define processing pipelines with interconnected nodes
  • Task context management: Centralized state enables data flow between nodes
  • Node-based architecture: Modular, reusable processing components
  • Schema validation: Built‑in checks ensure valid DAGs and clear structure
⌘I