Update celery_worker.py

celery_worker.py

@@ -1,11 +1,15 @@
 from celery import Celery
-from agents.strategy_agent import run_strategy
-from memory.database import log_action
+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():
-    result = run_strategy("fitness", "dropshipping")
+    sa = StrategyAgent()
+    result = sa.generate("fitness", "dropshipping")
     log_action("StrategyAgent", "scheduled_run", result)
     return result