feat: Add OpenTelemetry instrumentation and configuration for enhanced telemetry tracking

1 files changed, 2 insertions, 0 deletions

diff --git a/src/Enmarcha.Backend/Services/ArrivalsPipeline.cs b/src/Enmarcha.Backend/Services/ArrivalsPipeline.cs
index 57a46e1..4f49afe 100644
--- a/src/Enmarcha.Backend/Services/ArrivalsPipeline.cs
+++ b/src/Enmarcha.Backend/Services/ArrivalsPipeline.cs
@@ -53,8 +53,10 @@ public class ArrivalsPipeline
     /// </summary>
     public async Task ExecuteAsync(ArrivalsContext context)
     {
+        using var activity = Telemetry.Source.StartActivity("ArrivalsPipeline");
         foreach (var processor in _processors)
         {
+            using var processorActivity = Telemetry.Source.StartActivity($"Processor:{processor.GetType().Name}");
             await processor.ProcessAsync(context);
         }
     }