[apiserver/ingest] Pass correct args to CleanupStoredData

dilyevsky · dilyevsky · commit e689583b9900 · 2025-02-09T10:53:08.000-08:00
diff --git a/pkg/apiserver/ingest/edgefunction.go b/pkg/apiserver/ingest/edgefunction.go
@@ -179,7 +179,7 @@ Finalize:
 	if errors.As(err, &appErr) {
 		res.Err = appErr.Error()
 	}
-	cleanErr := workflow.ExecuteActivity(sessCtx, w.CleanupStagedData, in.Obj.Name).Get(ctx, nil)
+	cleanErr := workflow.ExecuteActivity(sessCtx, w.CleanupStagedData, in).Get(ctx, nil)
 	if cleanErr != nil {
 		log.Error("Failed to cleanup staged data", "Error", cleanErr)
 	}

Original file line number	Diff line number	Diff line change
`@@ -179,7 +179,7 @@ Finalize:`
`179`	`179`	`if errors.As(err, &appErr) {`
`180`	`180`	`res.Err = appErr.Error()`
`181`	`181`	`}`
`182`		`- cleanErr := workflow.ExecuteActivity(sessCtx, w.CleanupStagedData, in.Obj.Name).Get(ctx, nil)`
	`182`	`+ cleanErr := workflow.ExecuteActivity(sessCtx, w.CleanupStagedData, in).Get(ctx, nil)`
`183`	`183`	`if cleanErr != nil {`
`184`	`184`	`log.Error("Failed to cleanup staged data", "Error", cleanErr)`
`185`	`185`	`}`