code: def kill(self, task_id):
          
          logging.info('Kills task {}'.format(task_id))
          return self.driver.killTask(encode(task_id))
docs: Kills the specified task.
  
          Note that attempting to kill a task is currently not reliable.
          If, for example, a scheduler fails over while it was attempting to kill
          a task it will need to retry in the future.
          Likewise, if unregistered / disconnected, the request will be dropped
          (these semantics may be changed in the future).