Pipeline Executor Script

A command-line utility that executes data pipelines with configurable environments and runtime parameters.

Capabilities

Session creation and execution

Create a script that initializes a pipeline session and executes it with configurable options.

• Creates a session for the "local" environment and runs the default pipeline @test
• Creates a session with runtime parameters {"max_retries": 3} and runs the pipeline @test
• Creates a session for "production" environment and runs a specific pipeline named "data_processing" @test

Implementation

@generates

API

def execute_pipeline(env: str = None, pipeline_name: str = None, runtime_params: dict = None) -> dict:
    """
    Execute a Kedro pipeline with specified configuration.

    Args:
        env: The environment to run in (e.g., "local", "production"). If None, uses default.
        pipeline_name: Name of the pipeline to execute. If None, runs the default pipeline.
        runtime_params: Dictionary of runtime parameters to override configuration values.

    Returns:
        A dictionary containing the session_id and run status information.
    """
    pass

Dependencies { .dependencies }

kedro { .dependency }

Provides pipeline session management and execution capabilities.

@satisfied-by