toil.batchSystems.mesos.executor¶
Attributes¶
Classes¶
Part of Toil's Mesos framework, runs on a Mesos agent. A Toil job is passed to it via the |
Functions¶
|
Module Contents¶
- toil.batchSystems.mesos.executor.log¶
- class toil.batchSystems.mesos.executor.MesosExecutor¶
Bases:
pymesos.Executor
Part of Toil’s Mesos framework, runs on a Mesos agent. A Toil job is passed to it via the task.data field, and launched via call(toil.command).
- popenLock¶
- runningTasks¶
- workerCleanupInfo = None¶
- address = None¶
- id = None¶
- registered(driver, executorInfo, frameworkInfo, agentInfo)¶
Invoked once the executor driver has been able to successfully connect with Mesos.
- reregistered(driver, agentInfo)¶
Invoked when the executor re-registers with a restarted agent.
- disconnected(driver)¶
Invoked when the executor becomes “disconnected” from the agent (e.g., the agent is being restarted due to an upgrade).
- killTask(driver, taskId)¶
Kill parent task process and all its spawned children
- shutdown(driver)¶
- error(driver, message)¶
Invoked when a fatal error has occurred with the executor and/or executor driver.
- launchTask(driver, task)¶
Invoked by SchedulerDriver when a Mesos task should be launched by this executor
- frameworkMessage(driver, message)¶
Invoked when a framework message has arrived for this executor.
- toil.batchSystems.mesos.executor.main()¶