Bump version to 0.9.12.2; enable dynamic execution in PipelineManager and update remote 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.1"
+version = "0.9.12.2"
 keywords = ["hamilton", "workflow", "pipeline", "scheduler", "apscheduler", "dask", "ray"]
 dependencies = [
   'aiobotocore<2.18.0',

src/flowerpower/pipeline.py

@@ -261,7 +261,10 @@ def _get_driver(
         )
 
         if executor_ is not None:
-            dr = dr.with_remote_executor(executor_)
+
+            dr = dr.enable_dynamic_execution(
+                allow_experimental_mode=True
+            ).with_remote_executor(executor_)
 
         if len(adapters):
             dr = dr.with_adapters(*adapters)