use WQ coprocess feature by default

molmod · Dec 9, 2023 · 278b366 · 278b366
1 parent 8b8b2c4
commit 278b366
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/psiflow/execution.py b/psiflow/execution.py
@@ -258,8 +258,8 @@ def parse_config(yaml_dict: dict):
             "max_idletime": 20,
             "default_threads": 1,
             "htex_address": None,
-            # "use_workqueue": False,
-            "mode": "taskvine",
+            "mode": "workqueue",
+            "workqueue_use_coprocess": True,
         }
         forced = {
             "initialize_logging": False,  # manual; to move parsl.log one level up
@@ -330,6 +330,7 @@ def load(
         # create main parsl executors
         executors = []
         mode = psiflow_config.pop("mode")
+        use_coprocess = psiflow_config.pop("workqueue_use_coprocess")
         for definition in definitions:
             if definition.use_threadpool:
                 executor = ThreadPoolExecutor(
@@ -404,7 +405,7 @@ def load(
                     autocategory=False,
                     port=0,
                     max_retries=0,
-                    coprocess=False,
+                    coprocess=use_coprocess,
                     worker_options=" ".join(worker_options),
                 )
             else: