mycelyso.pilyso.pipeline package

Submodules

mycelyso.pilyso.pipeline.executor module

The executor submodule contains the PipelineExecutor, which runs an image processing pipeline.

class mycelyso.pilyso.pipeline.executor.Collected[source]

Bases: object

class mycelyso.pilyso.pipeline.executor.Every[source]

Bases: object

class mycelyso.pilyso.pipeline.executor.NotDispatchedYet[source]

Bases: object

class mycelyso.pilyso.pipeline.executor.PipelineExecutor[source]

Bases: object

close()[source]
get_cache(token)[source]
in_cache(token)[source]
initialize(pec, *args, **kwargs)[source]
multiprocessing = True
progress_tick()[source]
run()[source]
set_cache(token, result)[source]
set_progress_total(l)[source]
set_workload(meta_tuple, item_counts, processing_order)[source]
skip_callback(op, skipped)[source]
wait = 0.01
exception mycelyso.pilyso.pipeline.executor.Skip(meta)[source]

Bases: RuntimeWarning

meta = None
mycelyso.pilyso.pipeline.executor.get_progress_bar(n)[source]
mycelyso.pilyso.pipeline.executor.singleton_class_mapper(class_, what, args, kwargs)[source]

mycelyso.pilyso.pipeline.pipeline module

class mycelyso.pilyso.pipeline.pipeline.NeatDict[source]

Bases: dict

class mycelyso.pilyso.pipeline.pipeline.Pipeline[source]

Bases: object

add(what)[source]
call(parameter)[source]
class mycelyso.pilyso.pipeline.pipeline.PipelineEnvironment(**kwargs)[source]

Bases: object

KEY_COLLECTED = 'collected'
KEY_RESULT = 'result'
debug = False
debug_message(*args, **kwargs)[source]
static new_pipeline()[source]
prepare_call(call, di=None, result=None)[source]
reassemble_result(result, args, _call_return)[source]
run(pipeline_invocation, **kwargs)[source]
unwrap_result(result)[source]
wrap(what)[source]
wrap_result(result)[source]
class mycelyso.pilyso.pipeline.pipeline.PipelineExecutionContext[source]

Bases: object

add_stage(step, pipeline=None)[source]
dispatch(step, **kwargs)[source]
get_step_keys()[source]
class mycelyso.pilyso.pipeline.pipeline.PipelineInvocation(pipeline, parameter)[source]

Bases: object

mycelyso.pilyso.pipeline.pipeline.get_argnames_and_defaults(call)[source]

Module contents

The pipeline submodule contains the infrastructure for building image processing pipelines.