fix(export): delete temporary export directory after completion of re…

…mote export (#9206)
dgraph-io · Nov 4, 2024 · e5ad869 · e5ad869
1 parent 237dd74
commit e5ad869
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/worker/export.go b/worker/export.go
@@ -549,6 +549,14 @@ func (r *remoteExportStorage) OpenFile(fileName string) (*ExportWriter, error) {
 }
 
 func (r *remoteExportStorage) FinishWriting(w *Writers) (ExportedFiles, error) {
+
+	defer func() {
+		glog.Infof("Deleting temporary export directory %s\n", r.les.destination)
+		if err := os.RemoveAll(r.les.destination); err != nil {
+			glog.Errorf("error deleting temporary export directory: %w", err)
+		}
+	}()
+
 	files, err := r.les.FinishWriting(w)
 	if err != nil {
 		return nil, err