Skip to content

Commit 927e958

Browse files
committed
added test for lzin passthrough in workflows
1 parent d0385a2 commit 927e958

File tree

1 file changed

+16
-0
lines changed

1 file changed

+16
-0
lines changed

pydra/compose/tests/test_workflow_run.py

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
import typing as ty
77
import attr
88
from pathlib import Path
9+
from fileformats.generic import File
910
from pydra.engine.tests.utils import (
1011
Add2,
1112
Add2Wait,
@@ -4606,3 +4607,18 @@ def Worky(x: int, y: ty.List[int]):
46064607
outputs = Worky(x=10, y=[1, 2, 3, 4])(cache_root=tmp_path)
46074608
assert outputs.sum == 100
46084609
assert outputs.products == [10, 20, 30, 40]
4610+
4611+
4612+
def test_wf_lzin_passthrough(tmp_path: Path) -> None:
4613+
@workflow.define
4614+
def IdentityWorkflow(x: int) -> int:
4615+
return x
4616+
4617+
@workflow.define
4618+
def OuterWorkflow(x: int) -> int:
4619+
ident = workflow.add(IdentityWorkflow(x=x))
4620+
add2 = workflow.add(Add2(x=ident.out))
4621+
return add2.out
4622+
4623+
wf = OuterWorkflow(x=1)
4624+
assert wf(cache_root=tmp_path).out == 3

0 commit comments

Comments
 (0)