crosscluster/physical: tag stream ingestion processor id

Epic: none Release note: none
cockroachdb · Sep 20, 2024 · cbc4418 · cbc4418
1 parent 0827072
commit cbc4418
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/ccl/crosscluster/physical/stream_ingestion_processor.go b/pkg/ccl/crosscluster/physical/stream_ingestion_processor.go
@@ -389,6 +389,7 @@ func newStreamIngestionDataProcessor(
 // Start implements the RowSource interface.
 func (sip *streamIngestionProcessor) Start(ctx context.Context) {
 	ctx = logtags.AddTag(ctx, "job", sip.spec.JobID)
+	ctx = logtags.AddTag(ctx, "proc", sip.ProcessorID)
 	log.Infof(ctx, "starting ingest proc")
 	sip.agg = bulkutil.TracingAggregatorForContext(ctx)