jobman.sources package

Submodules

jobman.sources.base_source module

class jobman.sources.base_source.BaseSource(*args, key=None, jobman=None, **kwargs)

Bases: object

initialize()

query_jobs(query=None)

tick()

jobman.sources.dir_source module

class jobman.sources.dir_source.DirSource(*args, root_path=None, subdir_paths=None, job_spec_defaults=None, lock_file_name=None, transfer_fn=<function move>, initialize=True, **kwargs)

Bases: jobman.sources.base_source.BaseSource

DEFAULT_LOCK_FILE_NAME = 'JOBMAN__LOCK'

DEFAULT_SUBDIRS = {'inbox': 'inbox', 'queued': 'queued', 'completed': 'completed', 'failed': 'failed'}

FINISHED_TAG = 'FINISHED'

initialize()

tick()