# tasks.py
from celery_app import celery_app
from services.backtesting_service import run_backtesting

@celery_app.task(name="tasks.run_backtesting_task")
def run_backtesting_task(symbol, estrategia, timeHour, risk, desde, hasta):
    """
    Task idempotente. Devuelve el JSON final con data, totals, wins/losses.
    """
    result = run_backtesting(symbol, estrategia, timeHour, risk, desde, hasta)
    # Almacena el JSON completo como resultado del task (para poder consultarlo por task_id más adelante)
    return result