evalquiz_pipeline_server.tests.pipeline_execution package

Submodules

evalquiz_pipeline_server.tests.pipeline_execution.test_pipeline_execution module

class evalquiz_pipeline_server.tests.pipeline_execution.test_pipeline_execution.IncInternalPipelineModule[source]

Bases: InternalPipelineModule

Test InternalPipelineModule that increments an integer value.

async run(input: Any) → Any[source]

Incrementation function.

Parameters:

input (Any) – Integer value

Returns:

Integer value incremented by 1.

Return type:

Any

async evalquiz_pipeline_server.tests.pipeline_execution.test_pipeline_execution.test_linear_pipeline_execution() → None[source]

Tests execution of a Pipeline with 3 IncInternalPipelineModule instances.

evalquiz_pipeline_server.tests.pipeline_execution.test_pipeline_executor module

class evalquiz_pipeline_server.tests.pipeline_execution.test_pipeline_executor.TestInternalPipelineModule(pipeline_module: PipelineModule, split: bool = False, merge: bool = False)[source]

Bases: InternalPipelineModule

run(input: Any) → Any[source]

The execution logic of the pipeline module. Checks IO-types on runtime.

Parameters:

input (Any) – Input to pipeline implementation.

Returns:

Output of pipeline implementation.

Return type:

Any

evalquiz_pipeline_server.tests.pipeline_execution.test_pipeline_executor.pipeline_executor() → PipelineExecutor[source]
evalquiz_pipeline_server.tests.pipeline_execution.test_pipeline_executor.test_validate_implementation_for_pipeline(split_configurations: tuple[bool, bool, bool], merge_configurations: tuple[bool, bool, bool], expected: bool) → None[source]

Module contents