mirror of
https://github.com/langgenius/dify.git
synced 2026-08-24 12:32:54 -04:00
Blackoutta
31 lines
1.1 KiB
Python
31 lines
1.1 KiB
Python
"""Core exceptions shared by ops trace dispatchers and trace providers.
|
|
|
|
Provider packages may raise these types to request generic task behavior, but
|
|
generic Celery tasks should not import provider-specific exception classes.
|
|
"""
|
|
|
|
|
|
class RetryableTraceDispatchError(RuntimeError):
|
|
"""Base class for transient trace dispatch failures that Celery may retry."""
|
|
|
|
|
|
class TraceParentContextAccessError(RetryableTraceDispatchError):
|
|
"""Raised when unified parent context storage is temporarily unavailable."""
|
|
|
|
|
|
class InvalidTraceParentContextError(RuntimeError):
|
|
"""Raised when stored unified parent context cannot be safely restored."""
|
|
|
|
|
|
class PendingTraceParentContextError(RetryableTraceDispatchError):
|
|
"""Raised when a nested trace arrives before its parent span context is available."""
|
|
|
|
parent_node_execution_id: str
|
|
|
|
def __init__(self, parent_node_execution_id: str) -> None:
|
|
self.parent_node_execution_id = parent_node_execution_id
|
|
super().__init__(
|
|
"Pending trace parent context for parent_node_execution_id="
|
|
f"{parent_node_execution_id}. Retry after the parent span context is published."
|
|
)
|