16 lines
499 B
Python
16 lines
499 B
Python
|
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}
|