def launchTask (self, driver, task):

        ## NB: the following code runs on the Mesos slave (source of the resource offer)

        def run_task():
            logging.debug("Mesos Executor: requested task %s", task.task_id.value)

            update = mesos_pb2.TaskStatus()
            update.task_id.value = task.task_id.value
            update.state = mesos_pb2.TASK_RUNNING
            update.data = str("running discovery task")

            logging.debug(update.data)
            driver.sendStatusUpdate(update)

            update = mesos_pb2.TaskStatus()
            update.task_id.value = task.task_id.value
            update.state = mesos_pb2.TASK_FINISHED

            ## NB: TODO test port availability...
            update.data = str(dumps(get_telemetry(), indent=4))

            ## NB: TODO download tarball/container for service launch

            # notify scheduler: ready to launch service
            logging.debug(update.data)
            driver.sendStatusUpdate(update)

        # now create a thread to run the requested task: run tasks in
        # new threads or processes, rather than inside launchTask...
        # NB: gevent/coroutines/Greenlets conflict here... must run
        # those in a child shell process

        thread = Thread(target=run_task)
        thread.start()
Return the resource corresponding to all the authorizations.
dataset/ETHPy150Open ceteri/exelixi/src/resource.py/MesosExecutor.launchTask--crossover with--dataset/ETHPy150Open ducksboard/libsaas/libsaas/services/github/service.py/GitHub.authorizations