jobman.workers package

Submodules

jobman.workers.base_worker module

class jobman.workers.base_worker.BaseWorker(key=None, initialize=True, db_uri=None, dao=None, engine_spec=None, acceptance_fn_spec=None, logger=None)

Bases: object

exception IncompatibleJobError

Bases: Exception

class JOB_STATUSES

Bases: object

CLAIMED = 'CLAIMED'

COMPLETED = 'COMPLETED'

EXECUTED = 'EXECUTED'

FAILED = 'FAILED'

PENDING = 'PENDING'

RUNNING = 'RUNNING'

UNKNOWN = 'UNKNOWN'

can_accept_job(job=None)

dao

default_acceptance_fn(job=None, **kwargs)

generate_dao(db_uri=None)

get_keyed_states(keyed_metas=None)

initialize()

submit_job(job=None)

tick()

worker_job_to_worker_state(worker_job=None)

jobman.workers.batching_worker module

class jobman.workers.batching_worker.BatchingWorker(*args, batchable_filters=None, max_batchable_wait=120, target_batch_time=3600, default_job_time=300, **kwargs)

Bases: jobman.workers.base_worker.BaseWorker

tick()