import time

from config.celery import app


@app.task(bind=True)
def sample_task(self, duration: int = 1):
    """تسک نمونه برای تست. duration تعداد ثانیه‌ای که تسک طول می‌کشه."""
    for i in range(duration):
        self.update_state(
            state="PROGRESS",
            meta={"current": i + 1, "total": duration, "message": "در حال پردازش..."},
        )
        time.sleep(1)
    return {"status": "completed", "duration": duration}