diff --git a/lib/tasks/db.rake b/lib/tasks/db.rake
index 6b1a8b657b5..81087473a0e 100644
--- a/lib/tasks/db.rake
+++ b/lib/tasks/db.rake
@@ -80,6 +80,10 @@ class StdOutDemux
     (@data[Thread.current] ||= +"") << data
   end
 
+  def close
+    finish_chunk
+  end
+
   def finish_chunk
     data = @data[Thread.current]
     if data