File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change 28
28
from opentelemetry .metrics import Observation
29
29
from opentelemetry .sdk .metrics import MeterProvider
30
30
from opentelemetry .sdk .metrics ._internal .export import ConsoleMetricExporter , PeriodicExportingMetricReader
31
- from opentelemetry .sdk .resources import SERVICE_NAME , Resource
31
+ from opentelemetry .sdk .resources import HOST_NAME , SERVICE_NAME , Resource
32
32
33
33
from airflow .configuration import conf
34
34
from airflow .exceptions import AirflowProviderDeprecationWarning
40
40
get_validator ,
41
41
stat_name_otel_handler ,
42
42
)
43
+ from airflow .utils .net import get_hostname
43
44
44
45
if TYPE_CHECKING :
45
46
from opentelemetry .metrics import Instrument
@@ -410,7 +411,7 @@ def get_otel_logger(cls) -> SafeOtelLogger:
410
411
debug = conf .getboolean ("metrics" , "otel_debugging_on" )
411
412
service_name = conf .get ("metrics" , "otel_service" )
412
413
413
- resource = Resource (attributes = {SERVICE_NAME : service_name })
414
+ resource = Resource . create (attributes = {HOST_NAME : get_hostname (), SERVICE_NAME : service_name })
414
415
415
416
protocol = "https" if ssl_active else "http"
416
417
endpoint = f"{ protocol } ://{ host } :{ port } /v1/metrics"
You can’t perform that action at this time.
0 commit comments