feat: remove partitioned block

betarixm · Nov 26, 2023 · d522323 · d522323
1 parent 988008c
commit d522323
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/rpc/src/main/scala/WorkerServer.scala b/rpc/src/main/scala/WorkerServer.scala
@@ -148,6 +148,14 @@ class WorkerServer(
                 logger.debug(
                   s"[WorkerServer] Wrote partition to $partitionPath"
                 )
+
+                if (path.exists && path.isFile) {
+                  val result = path.delete()
+
+                  logger.debug(
+                    s"[WorkerServer] Deleted $path: $result"
+                  )
+                }
               })
 
           })