| 588 | from opentelemetry.exporter.cloud_trace import CloudTraceSpanExporter |
| 589 | |
| 590 | def register_processors(provider: TracerProvider) -> None: |
| 591 | envs.load_dotenv_for_agent("", agents_dir) |
| 592 | if project_id := os.environ.get("GOOGLE_CLOUD_PROJECT", None): |
| 593 | processor = export.BatchSpanProcessor( |
| 594 | CloudTraceSpanExporter(project_id=project_id) |
| 595 | ) |
| 596 | provider.add_span_processor(processor) |
| 597 | else: |
| 598 | logger.warning( |
| 599 | "GOOGLE_CLOUD_PROJECT environment variable is not set. Tracing will" |
| 600 | " not be enabled." |
| 601 | ) |
| 602 | |
| 603 | extra_fast_api_args.update( |
| 604 | register_processors=register_processors, |