diff --git a/pcore/pipeline.py b/pcore/pipeline.py
index 841493b355a268238847eb244324167d8f0a6374..9a36aa77638585fd0de0c898362171bdfe865add 100644
--- a/pcore/pipeline.py
+++ b/pcore/pipeline.py
@@ -16,7 +16,7 @@ from agora.base import ParametersABC, ProcessABC
 from pcore.experiment import MetaData
 from pcore.io.omero import Dataset, Image
 from pcore.haystack import initialise_tf
-from pcore.baby_client import DummyRunner
+from pcore.baby_client import BabyRunner
 from pcore.segment import Tiler
 from pcore.io.writer import TilerWriter, BabyWriter
 from pcore.io.signal import Signal
diff --git a/scripts/distributed_alan.py b/scripts/distributed_alan.py
index fd89c2640da36d8fe4f05cb2cbdbf70b005e7531..28bb68bd30c50a03d251ed3e18f5ac8ea198b255 100644
--- a/scripts/distributed_alan.py
+++ b/scripts/distributed_alan.py
@@ -19,7 +19,7 @@ import operator
 from pcore.experiment import MetaData
 from pcore.io.omero import Dataset, Image
 from pcore.haystack import initialise_tf
-from pcore.baby_client import DummyRunner
+from pcore.baby_client import BabyRunner
 from pcore.segment import Tiler
 from pcore.io.writer import TilerWriter, BabyWriter
 from pcore.utils import timed
@@ -79,7 +79,7 @@ def create_pipeline(image_id, **config):
             assert baby_config is not None  # TODO add defaults
             tf_version = baby_config.get("tf_version", 2)
             session = initialise_tf(tf_version)
-            runner = DummyRunner(tiler)
+            runner = BabyRunner(tiler)
             bwriter = BabyWriter(filename)
             params = Parameters(**exparams_from_meta(filename))
             ext = Extractor.from_tiler(params, store=filename, tiler=tiler)