add panic

rudderlabs · Jan 14, 2025 · b07c7f6 · b07c7f6
1 parent ad4fab8
commit b07c7f6
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/warehouse/router/upload.go b/warehouse/router/upload.go
@@ -368,6 +368,9 @@ func (job *UploadJob) run() (err error) {
 			}
 			newStatus = nextUploadState.completed
 			if job.config.cleanupStorageFiles {
+				if true {
+					panic("cleanupStorageFiles is not implemented")
+				}
 				warehouse := job.warehouse
 				storageProvider := whutils.ObjectStorageType(warehouse.Destination.DestinationDefinition.Name, warehouse.Destination.Config, job.upload.UseRudderStorage)
 				fm, err := filemanager.New(&filemanager.Settings{Provider: storageProvider, Config: warehouse.Destination.Config})