def run_with_octopus(&block)
        return run_without_octopus(&block) unless connection.is_a?(Octopus::Proxy)
        shards = migrations.map(&:shards).flatten.map(&:to_s)
        connection.send_queries_to_multiple_shards(shards) do
          run_without_octopus(&block)