xiaxinhang/pr-agent
1
0
Fork 0
mirror of https://github.com/qodo-ai/pr-agent.git synced 2025-07-05 21:30:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

Better error handling on backgrounp task thread

Browse Source
This commit is contained in:
MarkRx
2024-05-30 20:22:58 -04:00
parent c9c14c10b0
commit d9a7dae6c4
3 changed files with 15 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
pr_agent/servers/azuredevops_server_webhook.py
View File

@ -43,8 +43,11 @@ def handle_request(
log_context["api_url"] = url log_context["api_url"] = url
async def inner(): async def inner():
try:
with get_logger().contextualize(**log_context): with get_logger().contextualize(**log_context):
await PRAgent().handle_request(url, body) await PRAgent().handle_request(url, body)
except Exception as e:
get_logger().error(f"Failed to handle webhook: {e}")
background_tasks.add_task(inner) background_tasks.add_task(inner)

3
pr_agent/servers/bitbucket_server_webhook.py
View File

@ -27,8 +27,11 @@ def handle_request(
log_context["api_url"] = url log_context["api_url"] = url
async def inner(): async def inner():
try:
with get_logger().contextualize(**log_context): with get_logger().contextualize(**log_context):
await PRAgent().handle_request(url, body) await PRAgent().handle_request(url, body)
except Exception as e:
get_logger().error(f"Failed to handle webhook: {e}")
background_tasks.add_task(inner) background_tasks.add_task(inner)

3
pr_agent/servers/gitlab_webhook.py
View File

@ -29,8 +29,11 @@ def handle_request(background_tasks: BackgroundTasks, url: str, body: str, log_c
log_context["api_url"] = url log_context["api_url"] = url
async def inner(): async def inner():
try:
with get_logger().contextualize(**log_context): with get_logger().contextualize(**log_context):
await PRAgent().handle_request(url, body) await PRAgent().handle_request(url, body)
except Exception as e:
get_logger().error(f"Failed to handle webhook: {e}")
background_tasks.add_task(inner) background_tasks.add_task(inner)