scheduler.threads package

Submodules

scheduler.threads.base_thread module

Defines the base class for scheduler background threads

class scheduler.threads.base_thread.BaseSchedulerThread(name, throttle, warning_threshold)

Bases: object

This is the abstract base class for scheduler background threads

run()

The main run loop of the thread

shutdown()

Stops the thread from running

scheduler.threads.messaging module

Defines the class that manages the messaging background thread

class scheduler.threads.messaging.MessagingThread

Bases: scheduler.threads.base_thread.BaseSchedulerThread

This class manages the messaging background thread for the scheduler

add_initial_messages(messages)

Adds any initial messages to the thread

Parameters:messages (list()) – The initial messages

scheduler.threads.recon module

Defines the class that manages the reconciliation background thread

class scheduler.threads.recon.ReconciliationThread

Bases: scheduler.threads.base_thread.BaseSchedulerThread

This class manages the reconciliation background thread for the scheduler

scheduler.threads.schedule module

Defines the class that manages the scheduling background thread

class scheduler.threads.schedule.SchedulingThread(client)

Bases: scheduler.threads.base_thread.BaseSchedulerThread

This class manages the scheduling background thread for the scheduler

client

Returns the client

Returns:The client Return type:mesoshttp.client.MesosClient

scheduler.threads.scheduler_status module

Defines the class that manages the scheduler status background thread

class scheduler.threads.scheduler_status.SchedulerStatusThread

Bases: scheduler.threads.base_thread.BaseSchedulerThread

This class manages the scheduler status background thread for the scheduler

scheduler.threads.sync module

Defines the class that manages the synchronization background thread

class scheduler.threads.sync.SyncThread(driver)

Bases: scheduler.threads.base_thread.BaseSchedulerThread

This class manages the synchronization background thread for the scheduler

driver

Returns the driver

Returns:The driver Return type:mesoshttp.client.MesosClient.SchedulerDriver

scheduler.threads.task_handling module

Defines the class that manages the task handling background thread

class scheduler.threads.task_handling.TaskHandlingThread(driver)

Bases: scheduler.threads.base_thread.BaseSchedulerThread

This class manages the task handling background thread for the scheduler

driver

Returns the driver

Returns:The driver Return type:mesoshttp.client.MesosClient.SchedulerDriver

scheduler.threads.task_update module

Defines the class that manages the task update background thread

class scheduler.threads.task_update.TaskUpdateThread

Bases: scheduler.threads.base_thread.BaseSchedulerThread

This class manages the task update background thread for the scheduler

Module contents