pyjob.local module¶

class pyjob.local.LocalProcess(queue, kill_switch, directory=None, permit_nonzero=False, chdir=False)[source]¶

Bases: multiprocessing.context.Process

Extension to multiprocessing.Process for LocalTask

run()[source]¶

Method representing the LocalProcess activity

class pyjob.local.LocalTask(*args, **kwargs)[source]¶

Bases: pyjob.task.Task

Locally executable Task

close()[source]¶

Close this LocalTask after completion

info¶

LocalTask information

kill()[source]¶

Immediately terminate the LocalTask

nprocesses¶

Getter for the number of concurrent LocalProcess