this framework is a bit over-generic and doesn't catch type errors.

(in upcoming PR, for exmaple)

fresh_config style templatisation works just fine here IMO

Author: benclifford

parsl/tests/configs/local_threads_checkpoint.py

@@ -5,21 +5,21 @@
 
 import parsl
 from parsl import python_app
-from parsl.tests.configs.local_threads_checkpoint import fresh_config
+from parsl.config import Config
+from parsl.dataflow.memoization import BasicMemoizer
+from parsl.executors.threads import ThreadPoolExecutor
 
 
-@contextlib.contextmanager
-def parsl_configured(run_dir, **kw):
-    c = fresh_config()
-    c.run_dir = run_dir
-    for config_attr, config_val in kw.items():
-        setattr(c, config_attr, config_val)
-    dfk = parsl.load(c)
-    for ex in dfk.executors.values():
-        ex.working_dir = run_dir
-    yield dfk
-
-    parsl.dfk().cleanup()
+def parsl_configured(run_dir, memoizer):
+    return parsl.load(Config(
+        run_dir=str(run_dir),
+        executors=[
+            ThreadPoolExecutor(
+                label='local_threads_checkpoint',
+            )
+        ],
+        memoizer=memoizer
+    ))
 
 
 @python_app(cache=True)
@@ -32,11 +32,11 @@ def uuid_app():
 def test_loading_checkpoint(tmpd_cwd):
     """Load memoization table from previous checkpoint
     """
-    with parsl_configured(tmpd_cwd, checkpoint_mode="task_exit"):
+    with parsl_configured(tmpd_cwd, BasicMemoizer(checkpoint_mode="task_exit")):
         checkpoint_files = [os.path.join(parsl.dfk().run_dir, "checkpoint")]
         result = uuid_app().result()
 
-    with parsl_configured(tmpd_cwd, checkpoint_files=checkpoint_files):
+    with parsl_configured(tmpd_cwd, BasicMemoizer(checkpoint_files=checkpoint_files)):
         relaunched = uuid_app().result()
 
     assert result == relaunched, "Expected following call to uuid_app to return cached uuid"