processfactory

ProcessFactory API reference

class biomaj.process.processfactory.PostProcessFactory(bank, blocks=None, redis_client=None, redis_prefix=None)

Manage postprocesses

self.blocks: dict of meta processes status Each meta process status is a dict of process status

__init__(bank, blocks=None, redis_client=None, redis_prefix=None)

Creates a postprocess factory

Parameters:

• bank (biomaj.bank.Bank) – Bank
• blocks (dict) – initial status of block processes

run(simulate=False)

Run processes

Parameters:simulate (bool) – does not execute process Returns:status of execution - bool

class biomaj.process.processfactory.PreProcessFactory(bank, metas=None, redis_client=None, redis_prefix=None)

Manage preprocesses

__init__(bank, metas=None, redis_client=None, redis_prefix=None)

Creates a preprocess factory

Parameters:

• bank (biomaj.bank.Bank) – Bank
• metas (dict) – initial status of meta processes

run(simulate=False)

Run processes

Parameters:simulate (bool) – does not execute process Returns:status of execution - bool

class biomaj.process.processfactory.ProcessFactory(bank, redis_client=None, redis_prefix=None)

Manage process execution

__init__(bank, redis_client=None, redis_prefix=None)

x.__init__(…) initializes x; see help(type(x)) for signature

__weakref__

list of weak references to the object (if defined)

fill_tasks_in_threads(metas)

Dispatch meta processes in available threads

run(simulate=False)

Run processes

Parameters:simulate (bool) – does not execute process Returns:status of execution - bool

run_threads(simulate=False)

Start meta threads

Parameters:simulate (bool) – do not execute processes Returns:tuple global execution status and status per meta process

class biomaj.process.processfactory.RemoveProcessFactory(bank, metas=None, redis_client=None, redis_prefix=None)

Manage remove processes

__init__(bank, metas=None, redis_client=None, redis_prefix=None)

Creates a remove process factory

Parameters:

• bank (biomaj.bank.Bank) – Bank
• metas (dict) – initial status of meta processes

run(simulate=False)

Run processes

Parameters:simulate (bool) – does not execute process Returns:status of execution - bool