Merge pull request #9 from djarecka/mgxd-rf/submitter

adding one more case to submit_from_call

Author: mgxd

.pre-commit-config.yaml

@@ -9,7 +9,7 @@ repos:
     -   id: check-yaml
     -   id: check-added-large-files
 -   repo: https://github.com/psf/black
-    rev: 22.1.0
+    rev: 22.3.0
     hooks:
     -   id: black
 -   repo: https://github.com/codespell-project/codespell

pydra/engine/submitter.py

@@ -46,8 +46,8 @@ async def submit_from_call(self, runnable, rerun):
         This coroutine should only be called once per Submitter call,
         and serves as the bridge between sync/async lands.
 
-        There are 3 potential paths based on the type of runnable:
-
+        There are 4 potential paths based on the type of runnable:
+        0) Workflow has a different plugin than a submitter
         1) Workflow without State
         2) Task without State
         3) (Workflow or Task) with State
@@ -58,6 +58,10 @@ async def submit_from_call(self, runnable, rerun):
         if is_workflow(runnable):
             # connect and calculate the checksum of the graph before running
             runnable._connect_and_propagate_to_tasks(override_task_caches=True)
+            # 0
+            if runnable.plugin and runnable.plugin != self.plugin:
+                # if workflow has a different plugin it's treated as a single element
+                await self.worker.run_el(runnable, rerun=rerun)
             # 1
             if runnable.state is None:
                 await runnable._run(self, rerun=rerun)