enterprise-infrastructure

name	enterprise-infrastructure
description	Kailash enterprise infra: progressive levels, dialect SQL, scheduler (cron/interval), durable execution + checkpointing, task queues, worker registry, idempotency.

Enterprise Infrastructure - Skills

Comprehensive guide to Kailash's progressive infrastructure model for scaling from single-process SQLite to multi-worker PostgreSQL/MySQL deployments, plus the scheduler and durable-execution primitives that ship in kailash.runtime, kailash.middleware.gateway, and kailash.servers.

Primitive Inventory

Read this first before grepping the source tree. Every primitive listed below ships in the kailash package today.

Primitive	Module	Purpose
WorkflowScheduler	kailash.runtime.scheduler	Cron + interval + one-shot scheduling (APScheduler-backed SQLite jobstore)
FabricScheduler	dataflow.fabric.scheduler	DataFlow product-refresh cron (asyncio + croniter, supervised tasks)
ExecutionTracker	kailash.runtime.execution_tracker	Per-node checkpoint primitive (records completion + cached output)
Checkpoint / ExecutionJournal / DurableRequest	kailash.middleware.gateway.durable_request	Per-request event log + checkpoint blob + state machine
CheckpointManager + DBCheckpointStore	kailash.middleware.gateway.checkpoint_manager + kailash.infrastructure.checkpoint_store	Tiered checkpoint persistence (memory/disk/cloud + DB-backed durable store)
DurableWorkflowServer	kailash.servers.durable_workflow_server	Server-mode wiring of checkpointing + dedup + event store
SQLTaskQueue	kailash.infrastructure.task_queue	DB-backed work queue for distributed execution (FOR UPDATE SKIP LOCKED)
SQLWorkerRegistry	kailash.infrastructure.worker_registry	Worker-fleet membership + heartbeats + dead-worker reaping
IdempotentExecutor	kailash.infrastructure.idempotency	At-most-once execution semantics (claim-execute-store)
ConnectionManager	kailash.db.connection	Dialect-portable connection pooling

Features

The enterprise infrastructure layer provides:

• Progressive Infrastructure Model: Level 0 (SQLite, in-process) to Level 2 (multi-worker, shared database + queue)
• QueryDialect Strategy Pattern: Dialect-portable SQL across PostgreSQL, MySQL 8.0+, and SQLite
• ConnectionManager: Async connection pooling with dialect-aware placeholder translation
• StoreFactory: Singleton factory for creating store backends from KAILASH_DATABASE_URL
• SQL Task Queue: Database-backed task queue using FOR UPDATE SKIP LOCKED
• Worker Registry: Heartbeat monitoring and dead worker reaping
• IdempotentExecutor: Exactly-once workflow execution via claim-execute-store pattern
• WorkflowScheduler: Cron + interval + one-shot recurring workflow execution with persistent SQLite jobstore
• FabricScheduler: DataFlow-specific product-refresh cron with supervised asyncio tasks
• Durable execution: ExecutionTracker checkpoints + CheckpointManager tiered storage + DurableRequest resumable state machine + DurableWorkflowServer server-mode wiring
• Schema Versioning: kailash_meta table with downgrade protection

Quick Start

# Level 0: Zero config (default)
from kailash.runtime import LocalRuntime
runtime = LocalRuntime()  # SQLite stores, in-process

# Level 1: Set KAILASH_DATABASE_URL=postgresql://user:pass@localhost/kailash
# Auto-detects PG, all stores use shared ConnectionManager

# Level 2: Set KAILASH_QUEUE_URL=redis://localhost:6379/0
# OR KAILASH_QUEUE_URL=postgresql://user:pass@localhost/kailash

# Recurring schedules: APScheduler-backed cron + interval (persists across restarts)
from kailash.runtime.scheduler import WorkflowScheduler

scheduler = WorkflowScheduler()         # default jobstore: kailash_schedules.db
scheduler.start()
scheduler.schedule_cron(my_workflow, "0 22 * * *")        # daily 22:00 UTC
scheduler.schedule_interval(my_workflow, seconds=300)     # every 5 minutes

# Durable execution: server-mode with checkpointing + recovery
from kailash.servers.durable_workflow_server import DurableWorkflowServer

server = DurableWorkflowServer(enable_durability=True)    # default CheckpointManager

The user's workflow code is identical at all levels.

Reference Documentation

Core Patterns

• progressive-infrastructure - Level 0/1/2 model, StoreFactory, env vars, schema versioning
• dialect-portable-sql - QueryDialect strategy, ? placeholders, _validate_identifier()
• connection-manager-patterns - ConnectionManager lifecycle, transactions, driver behavior

Operations

• task-queue-patterns - SQL task queue, SKIP LOCKED, Redis vs SQL, worker registry
• idempotency-patterns - IdempotentExecutor, claim-execute-store, TTL expiry
• scheduler-patterns - WorkflowScheduler (cron + interval + one-shot), FabricScheduler (DataFlow product refresh), multi-instance hazards
• durability-patterns - ExecutionTracker per-node checkpoints, CheckpointManager + DBCheckpointStore, DurableWorkflowServer, resume-from-checkpoint contract

Key Concepts

Progressive Levels

Level	Config	Runtime	Persistence
0	None	In-process, LocalRuntime	SQLite + in-memory
1	KAILASH_DATABASE_URL	In-process, shared DB	PostgreSQL/MySQL/SQLite
2	KAILASH_QUEUE_URL	Multi-worker + task queue	Shared DB + Redis or SQL queue

Environment Variables

Variable	Purpose	Default
KAILASH_DATABASE_URL	Infrastructure stores	None (Level 0)
DATABASE_URL	Fallback for KAILASH_DATABASE_URL	None
KAILASH_QUEUE_URL	Task queue broker	None (no queue)

Source Code Layout

Package	Purpose

Critical Rules

• Use ? canonical placeholders in all SQL -- ConnectionManager translates automatically
• Validate all SQL identifiers with _validate_identifier() before interpolation
• Use dialect.upsert() instead of check-then-act (TOCTOU race)
• Use async with conn.transaction() as tx: for multi-statement operations
• Bound in-memory stores: OrderedDict with LRU eviction, max 10,000 entries
• Lazy imports for database drivers (aiosqlite, asyncpg, aiomysql)
• No AUTOINCREMENT in shared DDL (SQLite-specific)
• Share a single ConnectionManager via StoreFactory (never create separate instances per store)

When to Use This Skill

Use this skill when you need to:

• Scale from Level 0 (SQLite) to Level 1 (PostgreSQL) or Level 2 (multi-worker)
• Write dialect-portable SQL that works across PostgreSQL, MySQL, and SQLite
• Set up the StoreFactory for infrastructure store backends
• Implement task queue processing with SQL or Redis
• Add idempotency guarantees to workflow execution
• Manage worker registration and heartbeat monitoring
• Understand schema versioning and migration patterns
• Set up cron-driven workflow execution / replace an external cron daemon for Kailash workloads
• Add durable execution to LocalRuntime workflows so they resume on restart instead of restarting from zero
• Configure per-node checkpointing for long-running workflows where partial progress MUST survive a crash
• Build a workflow execution journal / audit trail of every state transition a request goes through
• Stand up a DurableWorkflowServer that wires checkpointing + dedup + event sourcing in one process

Related Skills

• 01-core-sdk - Core SDK workflow patterns (infrastructure backs execution)
• 02-dataflow - DataFlow for user data (infrastructure for runtime stores)
• 03-nexus - Multi-channel platform deployment

Support

For complex infrastructure questions, invoke:

• infrastructure-specialist - Progressive infrastructure, dialect portability, store factory
• testing-specialist - Infrastructure testing with real databases
• security-reviewer - SQL injection prevention, transaction safety