Planner → suggest_topic
    ↓ Telegram approval
Creator → create_post
    ↓ Telegram approval
Creator → create_visual_prompt → Flux/Veo
    ↓ Telegram approval
Reviewer → review_post (score)
    ↓ Telegram approval
Publisher → Instagram

IDLE → PLANNING → AWAITING_TOPIC_APPROVAL →
CREATING_CONTENT → AWAITING_CONTENT_APPROVAL →
CREATING_VISUAL → AWAITING_VISUAL_APPROVAL →
REVIEWING → AWAITING_FINAL_APPROVAL →
PUBLISHING → COMPLETED | ERROR

from app.scheduler.pipeline import ContentPipeline

pipeline = ContentPipeline(telegram_callback=callback)

# Daily (with approvals)
result = await pipeline.run_daily_content()

# Autonomous (no approvals, min_score=7)
result = await pipeline.run_autonomous_content(min_score=7)

# Reels
result = await pipeline.run_reels_content()

from app.agents.base_agent import BaseAgent

class MyAgent(BaseAgent):
    def __init__(self):
        super().__init__("myagent")  # Loads persona

    async def execute(self, input_data):
        response = await self.call_claude_with_retry(
            prompt="...",
            timeout=120,
            max_retries=3
        )
        return json.loads(response)

@retry_with_backoff(max_retries=3, base_delay=2.0)
# Delays: 2s, 4s, 8s (exponential)

# Success
{"success": True, "post_id": 123, "instagram_post_id": "..."}

# Error
{"success": False, "error": "...", "final_state": "error"}