Bump version to 0.9.9.29; update executor handling in PipelineManager to allow empty string as a valid executor option

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.9.28"
+version = "0.9.9.29"
 keywords = ["hamilton", "workflow", "pipeline", "scheduler", "apscheduler", "dask", "ray"]
 dependencies = [
   'aiobotocore<2.18.0',

src/flowerpower/pipeline.py

@@ -432,10 +432,10 @@ def run_job(
                 kwargs=kwargs,
                 job_executor=(
                     executor
-                    if executor in ["async", "threadpool", "processpool", None]
+                    if executor in ["async", "threadpool", "processpool", ""]
                     else "threadpool"
                     if executor == "future_adapter"
-                    else None
+                    else "threadpool"
                 ),
             )
 
@@ -513,10 +513,10 @@ def add_job(
                 kwargs=kwargs,
                 job_executor=(
                     executor
-                    if executor in ["async", "threadpool", "processpool", None]
+                    if executor in ["async", "threadpool", "processpool", ""]
                     else "threadpool"
                     if executor == "future_adapter"
-                    else None
+                    else "threadpool"
                 ),
                 result_expiration_time=result_expiration_time,
             )
@@ -657,10 +657,10 @@ def _get_id() -> str:
                 kwargs=kwargs,
                 job_executor=(
                     executor
-                    if executor in ["async", "threadpool", "processpool", None]
+                    if executor in ["async", "threadpool", "processpool", ""]
                     else "threadpool"
                     if executor == "future_adapter"
-                    else None
+                    else "threadpool"
                 ),
                 **schedule_kwargs,
             )