core.otlp.formatters ==================== .. py:module:: core.otlp.formatters .. autoapi-nested-parse:: Compatibility layer for legacy OTLP formatter imports. Classes ------- .. autoapisummary:: core.otlp.formatters.JobmonOTLPFormatter Functions --------- .. autoapisummary:: core.otlp.formatters.add_span_details_processor core.otlp.formatters.get_current_span_details Module Contents --------------- .. py:class:: JobmonOTLPFormatter(fmt=None, datefmt=None, style='%', validate=True, *, defaults=None) Bases: :py:obj:`logging.Formatter` Formatter that adds OpenTelemetry span details to jobmon logs. Note: For handlers using _JobmonOTLPLoggingHandler, this formatter is not used for OTLP output (handler creates OTLPLogRecord directly). It only affects console/file output. .. py:method:: format(record: logging.LogRecord) -> str Format log record with OpenTelemetry span details. .. py:function:: add_span_details_processor(logger: Any, method_name: str, event_dict: Dict[str, Any]) -> Dict[str, Any] Structlog processor to add OpenTelemetry span details to log entries. :param logger: The logger instance (not used, but required by Structlog processor signature). :param method_name: The logging method name (e.g., "info", "debug"). :param event_dict: The event dictionary representing the log entry. :returns: The modified event dictionary with OpenTelemetry span details added. .. py:function:: get_current_span_details() -> Tuple[Optional[str], Optional[str], Optional[str]] Get details of the current OpenTelemetry span. :returns: Tuple of (span_id, trace_id, parent_span_id) as hex strings, or (None, None, None)