// karen_code/automation.py
import asyncio
from karencode import Pipeline, Agent

class WorkflowEngine:
    def __init__(self):
        self.pipeline = Pipeline()
        self.agent    = Agent(model="gpt-4o")

    async def run(self, task: str):
        result = await self.agent.execute(
            prompt=task,
            tools=["search", "invoice"],
            temperature=0.2
        )
        return self.pipeline.process(result)

# --- entrypoint ---
if __name__ == "__main__":
    engine = WorkflowEngine()
    asyncio.run(engine.run(
        "automate invoice workflow"
    ))