fix(workflows/video): cleanup workflow is no stream found for save in…

…fo task
Zibbp · Mar 18, 2024 · 753e92b · 753e92b
1 parent b1d01f1
commit 753e92b
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/internal/workflows/video.go b/internal/workflows/video.go
@@ -359,6 +359,13 @@ func SaveTwitchLiveVideoInfoWorkflow(ctx workflow.Context, input dto.ArchiveVide
 
 	err := workflow.ExecuteActivity(ctx, activities.SaveTwitchLiveVideoInfo, input).Get(ctx, nil)
 	if err != nil {
+		if strings.Contains(err.Error(), "no stream found for channel") {
+			err := cancelWorkflowAndCleanup(context.Background(), input)
+			if err != nil {
+				return err
+			}
+			return err
+		}
 		return workflowErrorHandler(err, input, "save-video-info")
 	}