gmakstutis/openrag
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge pull request #602 from langflow-ai/scarf-fire-and-forget

Browse source 
fire and foreget
This commit is contained in:
Sebastián Estévez 2025-12-03 19:50:50 -05:00 • committed by GitHub
commit 3c83c72e46
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 25 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
src/utils/telemetry/client.py
View file

@ -294,18 +294,18 @@ async def _send_scarf_event(
)
return
except httpx.TimeoutException as e:
# Retry timeout errors
logger.error(
f"Failed to send telemetry event: {category}:{message_id}. "
f"Timeout error: {e}"
except httpx.TimeoutException:
# Don't retry timeouts - Scarf is slow/unreachable, retrying won't help
logger.warning(
f"Telemetry timeout for {category}:{message_id}, skipping retries"
)
except httpx.ConnectError as e:
# Retry connection errors
logger.error(
f"Failed to send telemetry event: {category}:{message_id}. "
f"Connection error: {e}"
return
except httpx.ConnectError:
# Don't retry connection errors - network is unreachable
logger.warning(
f"Telemetry connection failed for {category}:{message_id}, skipping retries"
)
return
except httpx.RequestError as e:
# Non-retryable request errors
logger.error(
@ -333,11 +333,14 @@ async def _send_scarf_event(
class TelemetryClient:
"""Telemetry client for sending events to Scarf."""
@staticmethod
async def send_event(category: str, message_id: str, metadata: dict = None) -> None:
"""Send a telemetry event asynchronously.
"""Send a telemetry event in the background (fire-and-forget).
This method creates a background task and returns immediately,
so telemetry never blocks application operations.
Args:
category: Event category
message_id: Event message ID
@ -348,11 +351,15 @@ class TelemetryClient:
f"Telemetry event aborted: {category}:{message_id}. DO_NOT_TRACK is enabled"
)
return
try:
await _send_scarf_event(category, message_id, metadata)
except Exception as e:
logger.error(f"Error sending telemetry event: {e}")
async def _send_with_error_handling():
try:
await _send_scarf_event(category, message_id, metadata)
except Exception as e:
logger.error(f"Error sending telemetry event: {e}")
# Fire and forget - don't block the caller
asyncio.create_task(_send_with_error_handling())
@staticmethod
def send_event_sync(category: str, message_id: str, metadata: dict = None) -> None: