jingrowlocal/jingrow-framework
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

删除一些调试日志

Browse Source
This commit is contained in:
jingrow 2025-10-31 20:43:21 +08:00
parent 603de3f0d5
commit 23bd2511d5
2 changed files with 1 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/jingrow/jingrow/core/hooks/executor.py
View File

@ -81,7 +81,7 @@ class HookExecutor:
results = await registry.send_async(hook_name, sender=sender, **kwargs) results = await registry.send_async(hook_name, sender=sender, **kwargs)
elapsed = time.time() - start_time elapsed = time.time() - start_time
if elapsed > 0.1: # 超过100ms记录警告 if elapsed > 1: # 超过1秒记录警告
logger.warning(f"异步钩子执行较慢: {hook_name} ({elapsed:.3f}s)") logger.warning(f"异步钩子执行较慢: {hook_name} ({elapsed:.3f}s)")
return results return results

5
apps/jingrow/jingrow/utils/jingrow_api.py
View File

@ -346,7 +346,6 @@ def push_local_job_to_jingrow(data: dict):
site_name = getattr(Config, "JINGROW_SITE", None) or os.getenv("JINGROW_SITE") site_name = getattr(Config, "JINGROW_SITE", None) or os.getenv("JINGROW_SITE")
if site_name: if site_name:
headers["X-Frappe-Site-Name"] = site_name headers["X-Frappe-Site-Name"] = site_name
log_info(f"[JFLOW->JINGROW] 准备推送 Local Job: job_id={data.get('job_id')} status={data.get('status')} queue={data.get('queue')}")
resp = requests.post(api_url, json=data, headers=headers, timeout=10) resp = requests.post(api_url, json=data, headers=headers, timeout=10)
if resp.status_code == 200: if resp.status_code == 200:
body = resp.json() body = resp.json()
@ -354,14 +353,10 @@ def push_local_job_to_jingrow(data: dict):
if isinstance(body, dict) and 'message' in body: if isinstance(body, dict) and 'message' in body:
body = body['message'] body = body['message']
if isinstance(body, dict) and body.get('success'): if isinstance(body, dict) and body.get('success'):
log_info(f"[JFLOW->JINGROW] 推送成功: job_id={data.get('job_id')} status={data.get('status')}")
return {'success': True} return {'success': True}
log_error(f"[JFLOW->JINGROW] 推送失败(body): {body}")
return {'success': False, 'error': str(body)} return {'success': False, 'error': str(body)}
log_error(f"[JFLOW->JINGROW] 推送失败(HTTP): {resp.status_code} {resp.text}")
return {'success': False, 'error': f"HTTP {resp.status_code}: {resp.text}"} return {'success': False, 'error': f"HTTP {resp.status_code}: {resp.text}"}
except Exception as e: except Exception as e:
log_error(f"[JFLOW->JINGROW] 推送异常: {str(e)}")
return {'success': False, 'error': f"推送 Local Job 失败: {str(e)}"} return {'success': False, 'error': f"推送 Local Job 失败: {str(e)}"}
def delete_record(pagetype: str, name: str): def delete_record(pagetype: str, name: str):