Update app.py
Browse files
app.py
CHANGED
|
@@ -61,7 +61,7 @@ diarize_pipeline = DiarizationPipeline.from_pretrained(
|
|
| 61 |
print("Speaker-diarization model ready!")
|
| 62 |
|
| 63 |
MIN_NOISE_BLOCK_SEC = 1.0
|
| 64 |
-
JOB_TTL_SECONDS =
|
| 65 |
STAGE_TIMEOUT_SEC = 1200 # سقف زمانی برای هر مرحلهی سنگین (۲۰ دقیقه - فقط محافظ آخر در برابر گیرکردن واقعی، نه محدودیت عادی)
|
| 66 |
|
| 67 |
# ─── نگهداری وضعیت کارها (Jobs) توی حافظه ───────────────────────────────────
|
|
@@ -483,7 +483,7 @@ def process_job(job_id):
|
|
| 483 |
traceback.print_exc()
|
| 484 |
update_job(job_id, status="error", error=str(e))
|
| 485 |
finally:
|
| 486 |
-
|
| 487 |
|
| 488 |
|
| 489 |
@app.get("/health")
|
|
|
|
| 61 |
print("Speaker-diarization model ready!")
|
| 62 |
|
| 63 |
MIN_NOISE_BLOCK_SEC = 1.0
|
| 64 |
+
JOB_TTL_SECONDS = 3 * 60 * 60 # کارهای قدیمی بعد از ۳ ساعت پاک میشن (برای فایلهای سنگین که ممکنه پردازششون طولانی بشه)
|
| 65 |
STAGE_TIMEOUT_SEC = 1200 # سقف زمانی برای هر مرحلهی سنگین (۲۰ دقیقه - فقط محافظ آخر در برابر گیرکردن واقعی، نه محدودیت عادی)
|
| 66 |
|
| 67 |
# ─── نگهداری وضعیت کارها (Jobs) توی حافظه ───────────────────────────────────
|
|
|
|
| 483 |
traceback.print_exc()
|
| 484 |
update_job(job_id, status="error", error=str(e))
|
| 485 |
finally:
|
| 486 |
+
pass # پاکسازی جداگانه و فقط موقع شروع کارهای جدید انجام میشه، نه بلافاصله بعد از اتمام همین کار
|
| 487 |
|
| 488 |
|
| 489 |
@app.get("/health")
|