code: async def cluster_failover(self, node_id, option):
          
          if not isinstance(option, str) or option.upper() not in {'FORCE', 'TAKEOVER'}:
              raise ClusterError('Wrong option provided')
          return await self.execute_command('CLUSTER FAILOVER', option, node_id=node_id)
docs: Forces a slave to perform a manual failover of its master
  
          Sends to specefied node