class Redis::Cluster

def call_pipeline(pipeline)
  node_keys = pipeline.commands.map { |cmd| find_node_key(cmd, primary_only: true) }.compact.uniq
  if node_keys.size > 1
    raise(CrossSlotPipeliningError,
          pipeline.commands.map { |cmd| @command.extract_first_key(cmd) }.reject(&:empty?).uniq)
  end
  try_send(find_node(node_keys.first), :call_pipeline, pipeline)
end