AI/ragflow
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/infiniflow/ragflow.git synced 2025-08-14 01:15:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update progress time info (#4193)

Browse Source 
### What problem does this PR solve?

Ignore the millisecond and microsecond value.

### Type of change

- [x] Refactoring

Signed-off-by: jinhai <haijin.chn@gmail.com>
This commit is contained in:
Jin Hai 2024-12-23 21:04:44 +08:00 committed by GitHub
parent a9fd6066d2
commit d030b4a680
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
api/db/services/task_service.py
View File

@ -85,7 +85,7 @@ class TaskService(CommonService):
if not docs: if not docs:
return None return None
msg = f"\n{datetime.now().strftime('%H:%M:%S.%f')} Task has been received." msg = f"\n{datetime.now().strftime('%H:%M:%S')} Task has been received."
prog = random.random() / 10.0 prog = random.random() / 10.0
if docs[0]["retry_count"] >= 3: if docs[0]["retry_count"] >= 3:
msg = "\nERROR: Task is abandoned after 3 times attempts." msg = "\nERROR: Task is abandoned after 3 times attempts."

2
rag/svr/task_executor.py
View File

@ -117,7 +117,7 @@ def set_progress(task_id, from_page=0, to_page=-1, prog=None, msg="Processing...
if msg: if msg:
msg = f"Page({from_page + 1}~{to_page + 1}): " + msg msg = f"Page({from_page + 1}~{to_page + 1}): " + msg
if msg: if msg:
msg = datetime.now().strftime("%H:%M:%S.%f") + " " + msg msg = datetime.now().strftime("%H:%M:%S") + " " + msg
d = {"progress_msg": msg} d = {"progress_msg": msg}
if prog is not None: if prog is not None:
d["progress"] = prog d["progress"] = prog