fix

Parsl · May 28, 2024 · 434f804 · 434f804
1 parent 2865342
commit 434f804
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 5 deletions.
diff --git a/parsl/executors/taskvine/manager.py b/parsl/executors/taskvine/manager.py
@@ -377,8 +377,11 @@ def _taskvine_submit_wait(ready_task_queue=None,
                         else:
                             task_in_file = _handle_file_declaration_protocol(m, spec.parsl_name, spec.cache)
                             parsl_file_name_to_vine_file[spec.parsl_name] = task_in_file
-                        logger.debug("Adding input file {}, {} to TaskVine".format(task_in_file, task.executor_id))
-                        t.add_input(task_in_file, spec.netloc)
+                        logger.debug("Adding input file {}, {} to TaskVine".format(spec.parsl_name, task.executor_id))
+                        if spec.netloc == '':
+                            t.add_input(task_in_file, spec.parsl_name)
+                        else:
+                            t.add_input(task_in_file, spec.netloc)
 
                 for spec in task.output_files:
                     if spec.stage:
@@ -387,8 +390,11 @@ def _taskvine_submit_wait(ready_task_queue=None,
                         else:
                             task_out_file = _handle_file_declaration_protocol(m, spec.parsl_name, spec.cache)
                             parsl_file_name_to_vine_file[spec.parsl_name] = task_out_file
-                        logger.debug("Adding output file {}, {} to TaskVine".format(task_out_file, task.executor_id))
-                        t.add_output(task_out_file, spec.netloc)
+                        logger.debug("Adding output file {}, {} to TaskVine".format(spec.parsl_name, task.executor_id))
+                        if spec.netloc == '':
+                            t.add_output(task_out_file, spec.parsl_name)
+                        else:
+                            t.add_output(task_out_file, spec.netloc)
 
             # Submit the task to the TaskVine object
             logger.debug("Submitting executor task {}, {} to TaskVine".format(task.executor_id, t))

diff --git a/parsl/executors/taskvine/stub_staging_provider.py b/parsl/executors/taskvine/stub_staging_provider.py
@@ -9,7 +9,7 @@
 
 logger = logging.getLogger(__name__)
 
-known_url_schemes = ["file", "http", "https", "taskvinetemp"]
+known_url_schemes = ["http", "https", "taskvinetemp"]
 
 
 class StubStaging(Staging, RepresentationMixin):