core.otlp.resources =================== .. py:module:: core.otlp.resources .. autoapi-nested-parse:: OpenTelemetry resource detection for jobmon. Classes ------- .. autoapisummary:: core.otlp.resources.ResourceDetector core.otlp.resources.BaseJobmonResourceDetector core.otlp.resources.ProcessResourceDetector core.otlp.resources.JobmonServiceResourceDetector core.otlp.resources.HostResourceDetector Functions --------- .. autoapisummary:: core.otlp.resources.create_jobmon_resources Module Contents --------------- .. py:class:: ResourceDetector .. py:function:: create_jobmon_resources() -> Optional[Any] Create OpenTelemetry resources for jobmon. .. py:class:: BaseJobmonResourceDetector Bases: :py:obj:`opentelemetry.sdk.resources.ResourceDetector` Base class for jobmon resource detectors that handles common logic. .. py:method:: detect() -> Optional[Any] Detect resource attributes using common jobmon logic. .. py:method:: _get_attributes(config: jobmon.core.configuration.JobmonConfig, deployment_environment: str) -> Dict[str, Any] :abstractmethod: Get detector-specific attributes. Must be implemented by subclasses. .. py:class:: ProcessResourceDetector Bases: :py:obj:`BaseJobmonResourceDetector` Detects process-related resource attributes. .. py:method:: _get_attributes(config: jobmon.core.configuration.JobmonConfig, deployment_environment: str) -> Dict[str, Any] Get process-specific attributes. .. py:class:: JobmonServiceResourceDetector Bases: :py:obj:`BaseJobmonResourceDetector` Detects jobmon service-related resource attributes. .. py:method:: _get_attributes(config: jobmon.core.configuration.JobmonConfig, deployment_environment: str) -> Dict[str, Any] Get jobmon service-specific attributes. .. py:class:: HostResourceDetector Bases: :py:obj:`BaseJobmonResourceDetector` Detects host-related resource attributes. .. py:method:: _get_attributes(config: jobmon.core.configuration.JobmonConfig, deployment_environment: str) -> Dict[str, Any] Get host-specific attributes.