Directory Structure¶

core/
├── interfaces/     # Core interfaces (abstract contracts)
│   └── executable_task.py  # ExecutableTask interface
├── base/           # Base class implementations
│   └── base_task.py  # BaseTask base class with common functionality
├── types.py        # Core type definitions (TaskTreeNode, TaskStatus, hooks)
├── decorators.py   # Unified decorators (Flask-style API)
│                    # register_pre_hook, register_post_hook, extension_register
├── config/         # Configuration registry
│   └── registry.py  # ConfigRegistry for hooks and TaskModel
├── execution/      # Task orchestration specifications
│   ├── task_manager.py      # TaskManager - core orchestration engine
│   ├── task_executor.py     # TaskExecutor - task execution interface
│   ├── task_creator.py      # TaskCreator - task tree creation and validation
│   ├── task_tracker.py      # TaskTracker - task execution tracking
│   ├── executor_registry.py # ExecutorRegistry - executor registration
│   └── streaming_callbacks.py  # Streaming support
├── extensions/     # Extension system
│   ├── base.py     # Extension base class
│   ├── decorators.py  # @extension_register decorator
│   ├── registry.py   # ExtensionRegistry
│   ├── protocol.py   # Protocol-based design (ExecutorLike, ExecutorFactory)
│   ├── types.py      # ExtensionCategory enum
│   ├── hook.py       # Hook system implementation
│   └── storage.py    # Storage extension base
├── storage/        # Storage implementation
│   ├── factory.py  # create_storage() function
│   ├── sqlalchemy/ # SQLAlchemy implementation
│   │   ├── models.py         # SQLAlchemy models
│   │   └── task_repository.py # Task repository implementation
│   └── dialects/   # Database dialects (DuckDB/PostgreSQL)
│       ├── duckdb.py
│       ├── postgres.py
│       └── registry.py
├── tools/          # Tool system
│   ├── base.py     # Tool base class
│   ├── decorators.py  # @tool_register decorator
│   └── registry.py   # ToolRegistry
└── utils/          # Utility functions
    ├── logger.py   # Logging utilities
    └── helpers.py  # Helper functions

extensions/crewai/
├── __init__.py
├── crew_manager.py     # CrewManager - CrewAI wrapper
├── batch_manager.py    # BatchManager - batch execution of multiple crews
└── types.py            # CrewManagerState, BatchState

extensions/stdio/
├── __init__.py
├── command_executor.py      # CommandExecutor - local command execution
└── system_info_executor.py  # SystemInfoExecutor - system resource queries

extensions/core/
├── __init__.py
└── aggregate_results_executor.py  # AggregateResultsExecutor - dependency result aggregation

extensions/hooks/
├── __init__.py
├── pre_execution_hook.py   # Pre-execution hook implementation
└── post_execution_hook.py  # Post-execution hook implementation

extensions/storage/
├── __init__.py
├── duckdb_storage.py   # DuckDB storage implementation
└── postgres_storage.py # PostgreSQL storage implementation

extensions/tools/
├── __init__.py
├── github_tools.py          # GitHub analysis tools
└── limited_scrape_tools.py   # Limited website scraping tools

api/
├── __init__.py            # API module exports
├── main.py                # API service entry point (supports protocol selection)
├── a2a/                   # A2A Protocol Server implementation
│   ├── __init__.py        # A2A module exports
│   ├── server.py          # A2A server creation
│   ├── agent_executor.py  # A2A agent executor
│   ├── custom_starlette_app.py  # Custom A2A Starlette application
│   └── event_queue_bridge.py    # Event queue bridge
├── routes/                 # Protocol-agnostic route handlers
│   ├── __init__.py        # Route handlers exports
│   ├── base.py            # BaseRouteHandler - shared functionality
│   ├── tasks.py           # TaskRoutes - task management handlers
│   └── system.py          # SystemRoutes - system operation handlers
└── rest/                  # REST API (future implementation)

tests/
├── conftest.py              # Shared fixtures and configuration
├── core/                    # Core framework tests
│   ├── execution/          # Task orchestration tests
│   │   ├── test_task_manager.py
│   │   ├── test_task_creator.py
│   │   └── test_task_executor_tools_integration.py
│   ├── storage/            # Storage tests
│   │   └── sqlalchemy/
│   │       └── test_task_repository.py
│   └── test_decorators.py  # Decorator tests
├── extensions/             # Extension tests
│   ├── core/
│   │   └── test_aggregate_results_executor.py
│   ├── crewai/
│   │   ├── test_crew_manager.py
│   │   └── test_batch_manager.py
│   ├── stdio/
│   │   ├── test_command_executor.py
│   │   └── test_system_info_executor.py
│   └── tools/
│       └── test_tools_decorator.py
├── api/                    # API service tests
│   └── a2a/
│       └── test_agent_executor.py  # A2A AgentExecutor tests
├── cli/                    # CLI tests
│   ├── test_run_command.py
│   └── test_tasks_command.py
└── integration/            # Integration tests
    └── test_aggregate_results_integration.py