scheduler.recon package¶

Submodules¶

Defines the class that manages reconciling tasks

class scheduler.recon.manager.ReconciliationManager¶

Bases: object

This class manages tasks that need to be reconciled. This class is thread-safe.

add_tasks(tasks)¶

Adds a list of tasks that need to be reconciled

Parameters:	tasks (`list()`) – The list of tasks to reconcile

driver¶

Returns the driver

Returns:	The driver
Return type:	`mesos_api.mesos.SchedulerDriver`

perform_reconciliation()¶: Performs task reconciliation with the Mesos master

remove_task_id(task_id)¶

Removes the task ID from the reconciliation set

Parameters:	task_id (string) – The task ID to remove