We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d3c3f70 commit 124aa7eCopy full SHA for 124aa7e
parsl/executors/taskvine/factory.py
@@ -1,4 +1,5 @@
1
import logging
2
+import os
3
4
from parsl.executors.taskvine.errors import TaskVineFactoryFailure
5
from parsl.process_loggers import wrap_with_logs
@@ -43,6 +44,9 @@ def _taskvine_factory(should_stop, factory_config):
43
44
factory.max_workers = factory_config.max_workers
45
factory.workers_per_cycle = factory_config.workers_per_cycle
46
47
+ # create scratch dir if factory process gets ahead of the manager.
48
+ os.makedirs(factory.scratch_dir, exist_ok=True)
49
+
50
if factory_config.worker_options:
51
factory.extra_options = factory_config.worker_options
52
factory.timeout = factory_config.worker_timeout
0 commit comments