celery_worker.py

from celery import Celery
from agents.strategy_agent import run_strategy
from memory.database import log_action

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

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