core.otlp.manager

Core OTLP manager for jobmon-scoped telemetry.

Classes

JobmonOTLPManager

Minimal OTLP manager for shared trace resources only.

Functions

initialize_jobmon_otlp(→ JobmonOTLPManager)	Initialize minimal OTLP for shared resources (traces only).
create_log_exporter(→ Optional[Any])	Create a pre-configured log exporter for client applications.

Module Contents

class core.otlp.manager.JobmonOTLPManager

Minimal OTLP manager for shared trace resources only.

With pure separation, this manager only handles: - Trace provider setup (for distributed tracing) - Resource detection (shared across components) - Request instrumentation (shared utility)

Log exporters are handled directly by handlers with pre-configured exporters.

_instance: JobmonOTLPManager | None = None

tracer_provider: Any | None = None

_initialized = False

classmethod get_instance() → JobmonOTLPManager

Get or create the singleton OTLP manager.

initialize() → None

Initialize trace provider with jobmon resources and configure span exporters.

_configure_span_exporters() → None

Configure span exporters from telemetry configuration.

_create_span_exporter(config: Any) → Any | None

Create a span exporter from configuration dictionary.

get_tracer(name: str) → Any | None

Get a tracer for distributed tracing.

classmethod instrument_requests() → None

Instrument requests library for HTTP tracing.

shutdown() → None

Shutdown trace provider.

core.otlp.manager.initialize_jobmon_otlp() → JobmonOTLPManager

Initialize minimal OTLP for shared resources (traces only).

For log export, use create_log_exporter() to get pre-configured exporters that can be passed to JobmonOTLPLoggingHandler.

Returns:

The minimal OTLP manager instance

core.otlp.manager.create_log_exporter(**kwargs: Any) → Any | None

Create a pre-configured log exporter for client applications.

This factory function creates exporters that can be passed to JobmonOTLPLoggingHandler for pure separation.

Parameters:

**kwargs – Exporter configuration (endpoint, headers, etc.)

Returns:

Pre-configured OTLP log exporter, or None if unavailable

Example

exporter = create_log_exporter(

endpoint=”otelcol.dev.aks:443”, max_batch_size=8

) handler = JobmonOTLPLoggingHandler(exporter=exporter)