(
otel_to_cloud: bool = False,
internal_exporters: Optional[list[SpanProcessor]] = None,
)
| 445 | |
| 446 | |
| 447 | def _setup_telemetry( |
| 448 | otel_to_cloud: bool = False, |
| 449 | internal_exporters: Optional[list[SpanProcessor]] = None, |
| 450 | ): |
| 451 | # TODO - remove the else branch here once maybe_set_otel_providers is no |
| 452 | # longer experimental. |
| 453 | if otel_to_cloud: |
| 454 | _setup_gcp_telemetry(internal_exporters=internal_exporters) |
| 455 | elif _otel_env_vars_enabled(): |
| 456 | _setup_telemetry_from_env(internal_exporters=internal_exporters) |
| 457 | else: |
| 458 | # Old logic - to be removed when above leaves experimental. |
| 459 | tracer_provider = TracerProvider() |
| 460 | if internal_exporters is not None: |
| 461 | for exporter in internal_exporters: |
| 462 | tracer_provider.add_span_processor(exporter) |
| 463 | trace.set_tracer_provider(tracer_provider=tracer_provider) |
| 464 | |
| 465 | |
| 466 | def _otel_env_vars_enabled() -> bool: |
no test coverage detected