NAME="Ubuntu"
VERSION_ID="24.04"
VERSION="24.04.1 LTS (Noble Numbat)"
VERSION_CODENAME=noble

- kfp==2.10.1
- kfp-pipeline-spec==0.5.0
- kfp-server-api==2.3.0
- Docker version 27.3.1, build ce12230

from kfp import local
from kfp import dsl

local.init(runner=local.DockerRunner())

@dsl.component
def add(a: int, b: int) -> int:
    return a + b

# run a single component
task = add(a=1, b=2)
assert task.output == 3

# or run it in a pipeline
@dsl.pipeline
def math_pipeline(x: int, y: int, z: int) -> int:
    t1 = add(a=x, b=y)
    t2 = add(a=t1.output, b=z)
    return t2.output

pipeline_task = math_pipeline(x=1, y=2, z=3)
assert pipeline_task.output == 6

ImportError: cannot import name 'local' from partially initialized module 'kfp' (most likely due to a circular import) (/home/ola/Code/mlops/apps/kfp.py)