celery_worker.py

from celery import Celery
from agents.strategy_agent import StrategyAgent
from memory.database import init_db, log_action

# Initialize DB on startup
init_db()

app = Celery("autoexec_ai", broker="redis://localhost:6379/0")

@app.task
def scheduled_loop():
    sa = StrategyAgent()
    result = sa.generate("fitness", "dropshipping")
    log_action("StrategyAgent", "scheduled_run", result)
    return result