Warn missing auth in workflow_run_streaming (#4178)
This commit is contained in:
committed by
GitHub
parent
6dad49eb08
commit
2961fdd721
@@ -14,7 +14,7 @@ import base64
|
|||||||
from datetime import datetime
|
from datetime import datetime
|
||||||
|
|
||||||
import structlog
|
import structlog
|
||||||
from fastapi import WebSocket, WebSocketDisconnect
|
from fastapi import HTTPException, WebSocket, WebSocketDisconnect
|
||||||
from pydantic import ValidationError
|
from pydantic import ValidationError
|
||||||
from websockets.exceptions import ConnectionClosedError, ConnectionClosedOK
|
from websockets.exceptions import ConnectionClosedError, ConnectionClosedOK
|
||||||
|
|
||||||
@@ -156,8 +156,8 @@ async def workflow_run_streaming(
|
|||||||
try:
|
try:
|
||||||
organization = await get_current_org(x_api_key=apikey, authorization=token)
|
organization = await get_current_org(x_api_key=apikey, authorization=token)
|
||||||
organization_id = organization.organization_id
|
organization_id = organization.organization_id
|
||||||
except Exception:
|
except HTTPException:
|
||||||
LOG.exception(
|
LOG.warning(
|
||||||
"WofklowRun Streaming: Error while getting organization",
|
"WofklowRun Streaming: Error while getting organization",
|
||||||
workflow_run_id=workflow_run_id,
|
workflow_run_id=workflow_run_id,
|
||||||
token=token,
|
token=token,
|
||||||
|
|||||||
Reference in New Issue
Block a user