core.otlp.resources

OpenTelemetry resource detection for jobmon.

Classes

ResourceDetector
BaseJobmonResourceDetector	Base class for jobmon resource detectors that handles common logic.
ProcessResourceDetector	Detects process-related resource attributes.
JobmonServiceResourceDetector	Detects jobmon service-related resource attributes.
HostResourceDetector	Detects host-related resource attributes.

Functions

create_jobmon_resources(→ Optional[Any])

Create OpenTelemetry resources for jobmon.

Module Contents

class core.otlp.resources.ResourceDetector

core.otlp.resources.create_jobmon_resources() → Any | None

Create OpenTelemetry resources for jobmon.

class core.otlp.resources.BaseJobmonResourceDetector

Bases: opentelemetry.sdk.resources.ResourceDetector

Base class for jobmon resource detectors that handles common logic.

detect() → Any | None

Detect resource attributes using common jobmon logic.

abstract _get_attributes(config: jobmon.core.configuration.JobmonConfig, deployment_environment: str) → Dict[str, Any]

Get detector-specific attributes. Must be implemented by subclasses.

class core.otlp.resources.ProcessResourceDetector

Bases: BaseJobmonResourceDetector

Detects process-related resource attributes.

_get_attributes(config: jobmon.core.configuration.JobmonConfig, deployment_environment: str) → Dict[str, Any]

Get process-specific attributes.

class core.otlp.resources.JobmonServiceResourceDetector

Bases: BaseJobmonResourceDetector

Detects jobmon service-related resource attributes.

_get_attributes(config: jobmon.core.configuration.JobmonConfig, deployment_environment: str) → Dict[str, Any]

Get jobmon service-specific attributes.

class core.otlp.resources.HostResourceDetector

Bases: BaseJobmonResourceDetector

Detects host-related resource attributes.

_get_attributes(config: jobmon.core.configuration.JobmonConfig, deployment_environment: str) → Dict[str, Any]

Get host-specific attributes.