try gevent

This commit is contained in:
Kenneth Kehl
2025-07-28 08:52:02 -07:00
parent f3e447fc2d
commit 143d57440c
8 changed files with 155 additions and 99 deletions

View File

@@ -1,6 +1,6 @@
import json
import eventlet
import gevent
from celery.signals import task_postrun
from flask import current_app
from requests import HTTPError, RequestException, request
@@ -84,7 +84,7 @@ def process_job(job_id, sender_id=None):
process_row(row, template, job, service, sender_id=sender_id)
count = count + 1
if count % 3 == 0:
eventlet.sleep(1)
gevent.sleep(1)
# End point/Exit point for message send flow.
job_complete(job, start=start)