Digital FTE Orchestrator Skill
Core task processing engine with Ralph Wiggum loop pattern.
Quick Start
# Normal mode
python src/orchestrator.py
# Process once and exit
python src/orchestrator.py --once
# Dry run (no execution)
python src/orchestrator.py --dry-run
# Via scripts
python scripts/run.py
Task Flow
Needs_Action/ → [Claim] → In_Progress/ → [Process] → Done/
↓
Pending_Approval/ (if sensitive)
↓
[Human approves]
↓
Approved/ → [Execute] → Done/
Work Zones
The orchestrator operates in different modes based on environment:
| Zone | FTE_ROLE |
Capabilities |
|---|---|---|
| Cloud | cloud |
Read-only, draft creation, analysis |
| Local | local |
Full execution, financial actions, posting |
Cloud Zone Restrictions
- All sends/posts forced to approval workflow
- Cannot execute financial transactions
- Cannot post to social media directly
- Creates drafts for human review
Local Zone Powers
- Direct execution of approved tasks
- Financial actions (with audit logging)
- Social media posting
- WhatsApp message sending
Claim-by-Move Pattern
Atomic task claiming prevents race conditions:
# ✓ CORRECT - Atomic claim
src = Needs_Action / task_file
dst = In_Progress / task_file
src.rename(dst) # Atomic on same filesystem
# ✗ WRONG - Race condition possible
if task_file in Needs_Action: # Another agent could claim here!
process(task_file)
Skill Routing
The orchestrator routes tasks to appropriate skills based on task type:
| Task Type | Skill | Example Trigger |
|---|---|---|
email_* |
sending-emails |
Email draft in queue |
whatsapp_* |
watching-whatsapp |
WhatsApp message request |
facebook_* |
posting-facebook |
Social media post |
invoice_* |
managing-odoo |
Create invoice request |
calendar_* |
managing-calendar |
Meeting request |
Agentic Intelligence
Integrated with src/intelligence/agentic_intelligence.py for:
- Task complexity scoring
- Autonomous decision making
- Learning from outcomes
- Pattern recognition
Configuration
| Flag | Default | Description |
|---|---|---|
--max-iterations |
10 | Max retries per task |
--poll-interval |
30 | Seconds between polls |
--dry-run |
false | Test without execution |
--once |
false | Process once and exit |
Environment:
FTE_ROLE=local|cloud # Determines work zone
CEO Briefing Integration
Orchestrator generates briefings via src/reports/ceo_briefing.py:
- Weekly activity summaries
- Key metrics and KPIs
- Task completion rates
- Pending approvals count
Verification
Run: python scripts/verify.py
Related Skills
sending-emails- Email sending patternswatching-whatsapp- WhatsApp monitoringmanaging-calendar- Calendar managementmanaging-odoo- Accounting operationsposting-facebook- Social media postinggenerating-ceo-briefing- Executive reports