Delete file

airbytehq · Nov 22, 2024 · 67e3595 · 67e3595
1 parent e45fa01
commit 67e3595
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/.../main/kotlin/io/airbyte/cdk/load/write/object_storage/ObjectStorageStreamLoaderFactory.kt b/.../main/kotlin/io/airbyte/cdk/load/write/object_storage/ObjectStorageStreamLoaderFactory.kt
@@ -129,10 +129,12 @@ class ObjectStorageStreamLoader<T : RemoteObject<*>, U : OutputStream>(
         )
 
         val metadata = ObjectStorageDestinationState.metadataFor(stream)
+        val localFile = File(file.fileMessage.fileUrl!!)
         val obj =
             client.streamingUpload(key, metadata, streamProcessor = compressor) { outputStream ->
-                File(file.fileMessage.fileUrl!!).inputStream().use { it.copyTo(outputStream) }
+                localFile.inputStream().use { it.copyTo(outputStream) }
             }
+        localFile.delete()
         return FinalizedObject(remoteObject = obj)
     }