class Redis::Cluster

def call_pipeline(pipeline) 

def call_pipeline(pipeline)
  node_keys, command_keys = extract_keys_in_pipeline(pipeline)
  raise CrossSlotPipeliningError, command_keys if node_keys.size > 1
  node = find_node(node_keys.first)
  try_send(node, :call_pipeline, pipeline)
end