diff --git a/src/redis-trib.rb b/src/redis-trib.rb index b6f6aba39f8ee2e363d45f9a5634c5df00163b62..92663eda8473929bb4dba011f2feef3c01eb2169 100755 --- a/src/redis-trib.rb +++ b/src/redis-trib.rb @@ -1023,8 +1023,15 @@ class RedisTrib # Migrate keys using the MIGRATE command. slot = key_to_slot(k) target = slots[slot] - puts "Migrating #{k} to #{target}" - source.client.call(["migrate",target.info[:host],target.info[:port],k,0,15000]) + print "Migrating #{k} to #{target}: " + STDOUT.flush + begin + source.client.call(["migrate",target.info[:host],target.info[:port],k,0,15000]) + rescue => e + puts e + else + puts "OK" + end } end end