From 9f43f9d21e94895db0b6e83a63d1f75b4b3b8fc3 Mon Sep 17 00:00:00 2001 From: Morgan Wowk Date: Mon, 17 Aug 2026 15:47:32 -0700 Subject: [PATCH] feat(orchestrator): trace output artifact info resolution (the freeze hot path) --- cloud_pipelines_backend/orchestrator_sql.py | 19 +++++++++++-------- 1 file changed, 11 insertions(+), 8 deletions(-) diff --git a/cloud_pipelines_backend/orchestrator_sql.py b/cloud_pipelines_backend/orchestrator_sql.py index 56ab7b8..fc470a8 100644 --- a/cloud_pipelines_backend/orchestrator_sql.py +++ b/cloud_pipelines_backend/orchestrator_sql.py @@ -1017,14 +1017,17 @@ def _maybe_preload_value( session=session, execution=execution_node ) else: - output_artifact_data_info_map = { - output_name: _retry( - lambda: self._storage_provider.make_uri(uri) - .get_reader() - .get_info() - ) - for output_name, uri in output_artifact_uris.items() - } + with orchestrator_tracing.operation_span( + "orchestrator.get_output_artifact_info" + ): + output_artifact_data_info_map = { + output_name: _retry( + lambda: self._storage_provider.make_uri(uri) + .get_reader() + .get_info() + ) + for output_name, uri in output_artifact_uris.items() + } new_output_artifact_data_map = { output_name: bts.ArtifactData( total_size=data_info.total_size,