Fix: Preventing Duplicate Migrations on the Same Shard

lib/octopus/migration.rb

@@ -99,7 +99,7 @@ class << self
 
       def run_with_octopus(&block)
         return run_without_octopus(&block) unless connection.is_a?(Octopus::Proxy)
-        shards = migrations.map(&:shards).flatten.map(&:to_s)
+        shards = migrations.map(&:shards).flatten.map(&:to_s).uniq
         connection.send_queries_to_multiple_shards(shards) do
           run_without_octopus(&block)
         end
@@ -109,7 +109,7 @@ def run_with_octopus(&block)
 
       def migrate_with_octopus(&block)
         return migrate_without_octopus(&block) unless connection.is_a?(Octopus::Proxy)
-        shards = migrations.map(&:shards).flatten.map(&:to_s)
+        shards = migrations.map(&:shards).flatten.map(&:to_s).uniq
         connection.send_queries_to_multiple_shards(shards) do
           migrate_without_octopus(&block)
         end

lib/octopus/version.rb

@@ -1,3 +1,3 @@
 module Octopus
-  VERSION = '0.10.2'
+  VERSION = '0.10.3'
 end