fix: stop swallowing exceptions in import fire-and-forget pipeline runners

src/SentenceStudio.Api/ChannelEndpoints.cs

@@ -1,5 +1,6 @@
 using System.Security.Claims;
 using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Logging;
 using SentenceStudio.Services;
 using SentenceStudio.Shared.Models;
 
@@ -111,7 +112,8 @@ private static async Task<IResult> TriggerCheck(
         string id,
         ClaimsPrincipal user,
         [FromServices] ChannelMonitorService channelService,
-        [FromServices] VideoImportPipelineService pipelineService)
+        [FromServices] VideoImportPipelineService pipelineService,
+        [FromServices] ILoggerFactory loggerFactory)
     {
         var userProfileId = user.FindFirstValue("user_profile_id");
         if (string.IsNullOrEmpty(userProfileId))
@@ -155,7 +157,9 @@ private static async Task<IResult> TriggerCheck(
                 }
                 catch (Exception ex)
                 {
-                    // Logging happens inside the pipeline service
+                    var logger = loggerFactory.CreateLogger(nameof(ChannelEndpoints));
+                    logger.LogError(ex, "Unhandled exception in import pipeline for import {ImportId}", import.Id);
+                    await pipelineService.FailImportAsync(import, ex.Message);
                 }
             });
 

src/SentenceStudio.Api/ImportEndpoints.cs

@@ -1,5 +1,6 @@
 using System.Security.Claims;
 using Microsoft.AspNetCore.Mvc;
+using Microsoft.Extensions.Logging;
 using SentenceStudio.Services;
 using SentenceStudio.Shared.Models;
 
@@ -55,7 +56,8 @@ private static async Task<IResult> GetImport(
     private static async Task<IResult> StartImport(
         [FromBody] StartImportRequest request,
         ClaimsPrincipal user,
-        [FromServices] VideoImportPipelineService pipelineService)
+        [FromServices] VideoImportPipelineService pipelineService,
+        [FromServices] ILoggerFactory loggerFactory)
     {
         var userProfileId = user.FindFirstValue("user_profile_id");
         if (string.IsNullOrEmpty(userProfileId))
@@ -82,7 +84,9 @@ private static async Task<IResult> StartImport(
             }
             catch (Exception ex)
             {
-                // Logging happens inside the pipeline service
+                var logger = loggerFactory.CreateLogger(nameof(ImportEndpoints));
+                logger.LogError(ex, "Unhandled exception in import pipeline for import {ImportId}", import.Id);
+                await pipelineService.FailImportAsync(import, ex.Message);
             }
         });
 
@@ -97,7 +101,8 @@ private static async Task<IResult> StartImport(
     private static async Task<IResult> RetryImport(
         string id,
         ClaimsPrincipal user,
-        [FromServices] VideoImportPipelineService pipelineService)
+        [FromServices] VideoImportPipelineService pipelineService,
+        [FromServices] ILoggerFactory loggerFactory)
     {
         var userProfileId = user.FindFirstValue("user_profile_id");
         if (string.IsNullOrEmpty(userProfileId))
@@ -132,7 +137,9 @@ private static async Task<IResult> RetryImport(
             }
             catch (Exception ex)
             {
-                // Logging happens inside the pipeline service
+                var logger = loggerFactory.CreateLogger(nameof(ImportEndpoints));
+                logger.LogError(ex, "Unhandled exception in import pipeline for import {ImportId}", import.Id);
+                await pipelineService.FailImportAsync(import, ex.Message);
             }
         });
 

src/SentenceStudio.Shared/Services/VideoImportPipelineService.cs

@@ -396,7 +396,7 @@ private async Task UpdateStatusAsync(VideoImport import, VideoImportStatus statu
         _logger.LogDebug("Import {Id} → {Status}", import.Id, status);
     }
 
-    private async Task FailImportAsync(VideoImport import, string errorMessage)
+    public async Task FailImportAsync(VideoImport import, string errorMessage)
     {
         import.Status = VideoImportStatus.Failed;
         import.ErrorMessage = errorMessage;