celery_worker.py

# celery_worker.py

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

# Initialize DB once
init_db()

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

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