unconditionally save tail state on initial import

stripe-archive · Dec 1, 2017 · 7426323 · 7426323
1 parent 98e282f
commit 7426323
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 8 deletions.
diff --git a/lib/mosql/streamer.rb b/lib/mosql/streamer.rb
@@ -80,12 +80,10 @@ def track_time
     def initial_import
       @schema.create_schema(@sql.db, !options[:no_drop_tables])
 
-      unless options[:skip_tail]
-        start_state = {
-          'time' => nil,
-          'position' => @tailer.most_recent_position
-        }
-      end
+      start_state = {
+        'time' => nil,
+        'position' => @tailer.most_recent_position
+      }
 
       dbnames = []
 
@@ -115,7 +113,7 @@ def initial_import
         end
       end
 
-      tailer.save_state(start_state) unless options[:skip_tail]
+      tailer.save_state(start_state)
     end
 
     def did_truncate; @did_truncate ||= {}; end

diff --git a/lib/mosql/version.rb b/lib/mosql/version.rb
@@ -1,3 +1,3 @@
 module MoSQL
-  VERSION = "0.4.3"
+  VERSION = "0.4.4"
 end