1 write to _activitySource
Microsoft.Extensions.DataIngestion (1)
IngestionPipeline.cs (1)
51_activitySource = new((options ?? new()).ActivitySourceName);
4 references to _activitySource
Microsoft.Extensions.DataIngestion (4)
IngestionPipeline.cs (4)
59_activitySource.Dispose(); 87using (Activity? rootActivity = _activitySource.StartActivity(ProcessDirectory.ActivityName)) 111using (Activity? rootActivity = _activitySource.StartActivity(ProcessFiles.ActivityName)) 143using (Activity? processFileActivity = _activitySource.StartActivity(ProcessFile.ActivityName, ActivityKind.Internal, parentContext: rootActivity?.Context ?? default))