<SYSTEM_TASK:>
Solve the following problem using Python, implementing the functions described below, one line at a time
<END_TASK>
<USER_TASK:>
Description:
 async def cluster_failover(self, node_id, option):
 """ Forces a slave to perform a manual failover of its master Sends to specefied node """

        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)