redis-trib import: trap MIGRATE errors.

solapvk · May 12, 2014 · 715a6d3 · 715a6d3
1 parent 939c586
commit 715a6d3
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/src/redis-trib.rb b/src/redis-trib.rb
@@ -1023,8 +1023,15 @@ def import_cluster_cmd(argv,opt)
                 # 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