scheduler.sync package

Submodules

scheduler.sync.job_type_manager module

Defines the class that manages the syncing of the scheduler with the job type models

class scheduler.sync.job_type_manager.JobTypeManager

Bases: object

This class manages the syncing of the scheduler with the job type models. This class is thread-safe.

generate_status_json(status_dict)

Generates the portion of the status JSON that describes the job types

Parameters:status_dict (dict) – The status JSON dict

get_job_type(job_type_id)

Returns the job type with the given ID, possibly None

Parameters:job_type_id (str) – The ID of the job type Returns:The job type for the given ID Return type:job.models.JobType

get_job_type_resources()

Returns a list of all of the job type resource requirements

Returns:The list of all of the job type resource requirements Return type:list()

get_job_types()

Returns a dict of all job types, stored by ID

Returns:The dict of all job types Return type:{int: job.models.JobType}

sync_with_database()

Syncs with the database to retrieve updated job type models

scheduler.sync.workspace_manager module

Defines the class that manages the syncing of the scheduler with the workspace models

class scheduler.sync.workspace_manager.WorkspaceManager

Bases: object

This class manages the syncing of the scheduler with the workspace models. This class is thread-safe.

get_workspaces()

Returns a dict of all workspaces, stored by name

Returns:The dict of all workspaces Return type:{string: storage.models.Workspace}

sync_with_database()

Syncs with the database to retrieve updated workspace models

Module contents