scheduler.tasks.services.messaging package

Submodules

scheduler.tasks.services.messaging.message_handler_task module

Defines the class for a message handler task

class scheduler.tasks.services.messaging.message_handler_task.MessageHandlerTask(framework_id)

Bases: scheduler.tasks.system_task.SystemTask

Represents a task that runs a message handler for processing the backend messaging system. This class is thread-safe.

get_resources()

See job.tasks.base_task.Task.get_resources()

scheduler.tasks.services.messaging.messaging_service module

Defines the messaging service that handles the backend messaging

class scheduler.tasks.services.messaging.messaging_service.MessagingService

Bases: scheduler.tasks.services.service.Service

Service that handles the backend messaging

get_desired_task_count()

See scheduler.tasks.services.service.Service.get_desired_task_count()

Module contents