Extract piped migration into Redis::PipedMigrator