zcr
18024a2d70
All checks were successful
git commit AiDA python develop 分支构建部署 / scheduled_deploy (push) Has been skipped
31 lines
789 B
Python
31 lines
789 B
Python
import logging
|
|
|
|
from app.service.utils.redis_utils import Redis
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
def update_progress(process_id, total):
|
|
# logger.info(f"{process_id} , {total}")
|
|
r = Redis()
|
|
progress = r.read(key=process_id)
|
|
if progress and total != 1:
|
|
if int(progress) <= 100:
|
|
r.write(key=process_id, value=int(progress) + int(100 / total))
|
|
else:
|
|
r.write(key=process_id, value=99)
|
|
return progress
|
|
elif total == 1:
|
|
r.write(key=process_id, value=100)
|
|
return progress
|
|
else:
|
|
r.write(key=process_id, value=int(100 / total))
|
|
return progress
|
|
|
|
|
|
def final_progress(process_id):
|
|
r = Redis()
|
|
progress = r.read(key=process_id)
|
|
r.write(key=process_id, value=100)
|
|
return progress
|