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.