lib/octopus/migration.rb in ar-octopus-0.0.25 vs lib/octopus/migration.rb in ar-octopus-0.0.26

@@ -9,23 +9,19 @@
       alias_method_chain :announce, :octopus
       attr_accessor :current_shard
     end
   end
 
-  def using(*args, &block)
-    if self.connection().is_a?(Octopus::Proxy) && !block_given?
+  def using(*args)
+    if self.connection().is_a?(Octopus::Proxy)
       args.each do |shard|
         self.connection().check_schema_migrations(shard)
       end
 
       self.connection().block = true
       self.current_shard = args
       self.connection().current_shard = args        
     end
-    
-    if block_given?
-      self.connection.run_queries_on_shard(args, &block)
-    end 
 
     return self
   end
 
   def using_group(*args)