Bump version to 0.9.12.3; enable dynamic execution in PipelineManager and streamline executor handling

Author: legout

pyproject.toml

@@ -4,7 +4,7 @@ description = "A simple workflow framework. Hamilton + APScheduler = FlowerPower
 authors = [{ name = "Volker L.", email = "[email protected]" }]
 readme = "README.md"
 requires-python = ">= 3.11"
-version = "0.9.12.2"
+version = "0.9.12.3"
 keywords = ["hamilton", "workflow", "pipeline", "scheduler", "apscheduler", "dask", "ray"]
 dependencies = [
   'aiobotocore<2.18.0',

src/flowerpower/pipeline.py

@@ -255,16 +255,15 @@ def _get_driver(
 
         dr = (
             driver.Builder()
+            .enable_dynamic_execution(allow_experimental_mode=True)
             .with_modules(self._module)
             .with_config(config)
             .with_local_executor(executors.SynchronousLocalTaskExecutor())
         )
 
         if executor_ is not None:
 
-            dr = dr.enable_dynamic_execution(
-                allow_experimental_mode=True
-            ).with_remote_executor(executor_)
+            dr = dr.with_remote_executor(executor_)
 
         if len(adapters):
             dr = dr.with_adapters(*adapters)