fix: record stopped sync jobs #30
|
|
@ -234,6 +234,8 @@ class Job(Controller):
|
|||
if not ans:
|
||||
logger.error(f"The job #{id} of project #{name} stop failed")
|
||||
raise Errors.UPDATE_FAILD
|
||||
log_service = LogService()
|
||||
await log_service.save_logs(id, LogType.INFO, f"The job #{id} of project {name} has been stopped")
|
||||
return Response(
|
||||
code=Code.SUCCESS,
|
||||
msg="关闭同步流成功"
|
||||
|
|
|
|||
Loading…
Reference in New Issue