.cursorignore
.dockerignore
.env.example
.gitignore
.gitmessage
.pre-commit-config.yaml
AGENTS.md
CHANGELOG.md
CLAUDE.md
Dockerfile
LICENSE
Makefile
README.md
apflow-logo.svg
docker-compose.yml
mkdocs.yml
pyproject.toml
pyrightconfig.json
pytest.ini
uv.lock
.cursor/rules/code.mdc
.devcontainer/devcontainer.json
.github/CODEOWNERS
.github/copilot-ignore
.github/copilot-instructions.md
.github/workflows/ci.yml
.github/workflows/docs.yml
.github/workflows/import-performance.yml
docs/llms.txt
docs/prd.md
docs/tech-design.md
docs/architecture/configuration.md
docs/architecture/exception-handling.md
docs/architecture/extension-registry-design.md
docs/architecture/task-orchestration.md
docs/assets/favicon.ico
docs/assets/logo.svg
docs/features/apcore-bridge.md
docs/features/cost-governance.md
docs/features/durable-execution.md
docs/features/function-executor.md
docs/features/overview.md
docs/features/project-slimming.md
docs/features/rest-api.md
docs/features/scheduler.md
docs/features/storage-migration.md
docs/features/task-creator-relaxation.md
docs/getting-started/concepts.md
docs/getting-started/installation.md
docs/getting-started/quick-start.md
docs/guides/environment-variables.md
docs/guides/task-orchestration.md
docs/scripts/generate_executor_docs.py
examples/quickstart.py
src/apflow/__init__.py
src/apflow/app.py
src/apflow/cli.py
src/apflow/logger.py
src/apflow/py.typed
src/apflow.egg-info/PKG-INFO
src/apflow.egg-info/SOURCES.txt
src/apflow.egg-info/dependency_links.txt
src/apflow.egg-info/entry_points.txt
src/apflow.egg-info/requires.txt
src/apflow.egg-info/top_level.txt
src/apflow/adapters/__init__.py
src/apflow/adapters/function_executor.py
src/apflow/api/__init__.py
src/apflow/api/auth.py
src/apflow/api/combined.py
src/apflow/api/rest.py
src/apflow/api/webhook.py
src/apflow/bridge/__init__.py
src/apflow/bridge/errors.py
src/apflow/bridge/module_adapter.py
src/apflow/bridge/registry_setup.py
src/apflow/bridge/scanner_bridge.py
src/apflow/bridge/schedule_modules.py
src/apflow/bridge/task_modules.py
src/apflow/core/__init__.py
src/apflow/core/builders.py
src/apflow/core/config_manager.py
src/apflow/core/decorators.py
src/apflow/core/types.py
src/apflow/core/base/__init__.py
src/apflow/core/base/base_task.py
src/apflow/core/config/__init__.py
src/apflow/core/config/registry.py
src/apflow/core/distributed/__init__.py
src/apflow/core/distributed/config.py
src/apflow/core/distributed/events.py
src/apflow/core/distributed/idempotency.py
src/apflow/core/distributed/leader_election.py
src/apflow/core/distributed/lease_manager.py
src/apflow/core/distributed/node_registry.py
src/apflow/core/distributed/placement.py
src/apflow/core/distributed/runtime.py
src/apflow/core/distributed/types.py
src/apflow/core/distributed/worker.py
src/apflow/core/execution/__init__.py
src/apflow/core/execution/errors.py
src/apflow/core/execution/streaming_callbacks.py
src/apflow/core/execution/task_creator.py
src/apflow/core/execution/task_executor.py
src/apflow/core/execution/task_manager.py
src/apflow/core/execution/task_tracker.py
src/apflow/core/extensions/__init__.py
src/apflow/core/extensions/base.py
src/apflow/core/extensions/decorators.py
src/apflow/core/extensions/executor_metadata.py
src/apflow/core/extensions/hook.py
src/apflow/core/extensions/manager.py
src/apflow/core/extensions/protocol.py
src/apflow/core/extensions/registry.py
src/apflow/core/extensions/scanner.py
src/apflow/core/extensions/storage.py
src/apflow/core/extensions/types.py
src/apflow/core/interfaces/__init__.py
src/apflow/core/interfaces/executable_task.py
src/apflow/core/storage/__init__.py
src/apflow/core/storage/context.py
src/apflow/core/storage/factory.py
src/apflow/core/storage/migrate.py
src/apflow/core/storage/dialects/__init__.py
src/apflow/core/storage/dialects/postgres.py
src/apflow/core/storage/dialects/registry.py
src/apflow/core/storage/dialects/sqlite.py
src/apflow/core/storage/migrations/001_add_task_tree_fields.py
src/apflow/core/storage/migrations/002_add_scheduling_fields.py
src/apflow/core/storage/migrations/003_add_distributed_support.py
src/apflow/core/storage/migrations/004_add_durability_and_governance.py
src/apflow/core/storage/migrations/005_add_idempotency_key_unique_index.py
src/apflow/core/storage/migrations/__init__.py
src/apflow/core/storage/sqlalchemy/__init__.py
src/apflow/core/storage/sqlalchemy/models.py
src/apflow/core/storage/sqlalchemy/schedule_calculator.py
src/apflow/core/storage/sqlalchemy/task_repository.py
src/apflow/core/utils/__init__.py
src/apflow/core/utils/helpers.py
src/apflow/core/utils/network_security.py
src/apflow/core/utils/project_detection.py
src/apflow/core/validator/__init__.py
src/apflow/core/validator/dependency_validator.py
src/apflow/core/validator/user_validator.py
src/apflow/durability/__init__.py
src/apflow/durability/checkpoint.py
src/apflow/durability/circuit_breaker.py
src/apflow/durability/retry.py
src/apflow/extensions/__init__.py
src/apflow/extensions/apflow/__init__.py
src/apflow/extensions/apflow/api_executor.py
src/apflow/extensions/core/__init__.py
src/apflow/extensions/core/aggregate_results_executor.py
src/apflow/extensions/email/__init__.py
src/apflow/extensions/email/send_email_executor.py
src/apflow/extensions/hooks/__init__.py
src/apflow/extensions/hooks/post_execution_hook.py
src/apflow/extensions/hooks/pre_execution_hook.py
src/apflow/extensions/http/__init__.py
src/apflow/extensions/http/rest_executor.py
src/apflow/extensions/storage/__init__.py
src/apflow/extensions/storage/postgres_storage.py
src/apflow/extensions/storage/sqlite_storage.py
src/apflow/governance/__init__.py
src/apflow/governance/budget.py
src/apflow/governance/policy.py
src/apflow/governance/provider_router.py
src/apflow/governance/reporter.py
src/apflow/scheduler/__init__.py
src/apflow/scheduler/base.py
src/apflow/scheduler/internal.py
src/apflow/scheduler/gateway/__init__.py
src/apflow/scheduler/gateway/ical.py
src/apflow/scheduler/gateway/webhook.py
tests/__init__.py
tests/conftest.py
tests/test_app.py
tests/test_docker_config.py
tests/test_logger.py
tests/test_security_review_fixes.py
tests/test_v2_slimming.py
tests/adapters/__init__.py
tests/adapters/test_function_executor.py
tests/api/test_auth.py
tests/api/test_combined.py
tests/api/test_rest_adapter.py
tests/api/test_webhook.py
tests/bridge/__init__.py
tests/bridge/test_error_taxonomy.py
tests/bridge/test_module_adapter.py
tests/bridge/test_registry_setup.py
tests/bridge/test_scanner_bridge.py
tests/bridge/test_schedule_modules.py
tests/bridge/test_task_modules.py
tests/cli/test_cli_bootstrap.py
tests/cli/test_scheduler_command.py
tests/cli/test_worker_command.py
tests/core/__init__.py
tests/core/test_config_manager.py
tests/core/test_config_manager_v2.py
tests/core/test_decorators.py
tests/core/test_demo_mode.py
tests/core/test_executor_hooks.py
tests/core/test_executor_metadata.py
tests/core/test_extension_scanner.py
tests/core/test_extensions_manager.py
tests/core/test_task_builder.py
tests/core/test_task_tree_hooks.py
tests/core/execution/__init__.py
tests/core/execution/test_breaker_gating.py
tests/core/execution/test_group_g_review_fixes.py
tests/core/execution/test_structured_errors.py
tests/core/execution/test_task_concurrency.py
tests/core/execution/test_task_creator.py
tests/core/execution/test_task_creator_review_fixes.py
tests/core/execution/test_task_executor_additional.py
tests/core/execution/test_task_executor_concurrent.py
tests/core/execution/test_task_failure_handling.py
tests/core/execution/test_task_manager.py
tests/core/execution/test_task_reexecution.py
tests/core/execution/test_task_tracker.py
tests/core/storage/__init__.py
tests/core/storage/test_context.py
tests/core/storage/test_database_path_priority.py
tests/core/storage/test_hook_context.py
tests/core/storage/test_hook_modify_task_with_context.py
tests/core/storage/test_migration.py
tests/core/storage/test_sqlite_session.py
tests/core/storage/dialects/__init__.py
tests/core/storage/dialects/test_registry.py
tests/core/storage/dialects/test_sqlite_dialect.py
tests/core/storage/sqlalchemy/__init__.py
tests/core/storage/sqlalchemy/conftest.py
tests/core/storage/sqlalchemy/test_custom_task_model.py
tests/core/storage/sqlalchemy/test_flag_modified.py
tests/core/storage/sqlalchemy/test_repository_tree_fixes.py
tests/core/storage/sqlalchemy/test_scheduling.py
tests/core/storage/sqlalchemy/test_session_pool.py
tests/core/storage/sqlalchemy/test_task_repository.py
tests/core/storage/sqlalchemy/test_task_repository_additional.py
tests/core/utils/__init__.py
tests/core/utils/test_helpers.py
tests/core/utils/test_project_detection.py
tests/core/validator/test_dependency_validator.py
tests/durability/__init__.py
tests/durability/test_checkpoint.py
tests/durability/test_circuit_breaker.py
tests/durability/test_integration.py
tests/durability/test_retry.py
tests/extensions/__init__.py
tests/extensions/apflow/__init__.py
tests/extensions/apflow/test_api_executor.py
tests/extensions/core/__init__.py
tests/extensions/core/test_aggregate_results_executor.py
tests/extensions/email/__init__.py
tests/extensions/email/test_send_email_executor.py
tests/extensions/http/__init__.py
tests/extensions/http/test_rest_executor.py
tests/governance/__init__.py
tests/governance/test_budget.py
tests/governance/test_integration.py
tests/governance/test_policy.py
tests/governance/test_provider_router.py
tests/governance/test_reporter.py
tests/integration/__init__.py
tests/integration/test_config_manager_integration.py
tests/performance/conftest.py
tests/performance/test_memory_leaks.py
tests/scheduler/__init__.py
tests/scheduler/test_distributed_scheduling_e2e.py
tests/scheduler/test_ical.py
tests/scheduler/test_scheduler.py
tests/scheduler/test_scheduler_history.py
tests/scheduler/test_webhook_gateway.py
tests/unit/distributed/__init__.py
tests/unit/distributed/conftest.py
tests/unit/distributed/test_distributed_config.py
tests/unit/distributed/test_distributed_models.py
tests/unit/distributed/test_events.py
tests/unit/distributed/test_idempotency.py
tests/unit/distributed/test_leader_election.py
tests/unit/distributed/test_lease_manager.py
tests/unit/distributed/test_node_registry.py
tests/unit/distributed/test_placement.py
tests/unit/distributed/test_review_fixes.py
tests/unit/distributed/test_runtime.py
tests/unit/distributed/test_worker.py
tests/unit/execution/__init__.py
tests/unit/execution/test_task_executor_distributed.py