Allow disable switcher

soundcloud · Jan 26, 2018 · 28b35e5 · 28b35e5
1 parent 0a192db
commit 28b35e5
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 3 deletions.
diff --git a/lib/lhm.rb b/lib/lhm.rb
@@ -55,6 +55,7 @@ def sync_table(table_name, sync_table, options = {}, &block)
     origin = Table.parse(table_name, connection)
     invoker = Invoker.new(origin, connection)
     block.call(invoker.migrator)
+    options.merge!({disable_switcher: true})
     invoker.run(options)
   ensure
     Lhm::Table.naming_strategy = nil

diff --git a/lib/lhm/invoker.rb b/lib/lhm/invoker.rb
@@ -44,10 +44,14 @@ def run(options = {})
 
       Entangler.new(migration, @connection).run do
         Chunker.new(migration, @connection, options).run
-        if options[:atomic_switch]
-          AtomicSwitcher.new(migration, @connection).run
+        if options[:disable_switcher]
+          Lhm.logger.debug 'switcher is disabled'
         else
-          LockedSwitcher.new(migration, @connection).run
+          if options[:atomic_switch]
+            AtomicSwitcher.new(migration, @connection).run
+          else
+            LockedSwitcher.new(migration, @connection).run
+          end
         end
       end
     end