Fix Storj delimiter while removing unused assets

livepeer · Jun 17, 2024 · d0022c2 · d0022c2
1 parent ab118fd
commit d0022c2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/task/runner.go b/task/runner.go
@@ -623,13 +623,13 @@ func deleteAsset(asset *api.Asset, r *runner, ctx context.Context) error {
 		return err
 	}
 
-	directory := fmt.Sprintf("%s/", asset.PlaybackID)
+	directory := fmt.Sprintf("hls/%s/", asset.PlaybackID)
 	var totalDeleted int
 
 	glog.Infof("Listing files in directory %v", directory)
 
 	// Initially list files
-	pi, err := assetOS.ListFiles(ctx, directory, "")
+	pi, err := assetOS.ListFiles(ctx, directory, "/")
 	if err != nil {
 		glog.Errorf("Error listing files for asset %v: %v", asset.ID, err)
 		return err