rich-garden-69988
04/18/2022, 3:30 PM>>
could be supported locally - I tried running a local execution this morning with that syntax and got a TypeError
- I can file a bug report on GitHub if helpful!rich-garden-69988
04/18/2022, 3:31 PMfrom flytekit import task, workflow
@task
def task_a(x: int) -> int:
return x
@task
def task_b(x: int) -> int:
return x
@workflow
def test(x: int) -> int:
a = task_a(x=x)
b = task_b(x=x)
a >> b
return a
if __name__ == "__main__":
test(x=1)
When trying to run I get:
TypeError: unsupported operand type(s) for >>: 'Promise' and 'Promise'
glamorous-carpet-83516
04/18/2022, 4:05 PM@task
def task_c(x: int, y: int) -> int:
return x >> y
@workflow
def test(x: int) -> int:
a = task_a(x=x)
b = task_b(x=x)
return task_c(x=a, y=b)
rich-garden-69988
04/18/2022, 4:06 PMmagnificent-teacher-86590
04/18/2022, 4:06 PMcreate_node
works within the workflow locally, though not very elegant compared to >>
freezing-airport-6809
freezing-airport-6809
freezing-airport-6809
freezing-airport-6809
rich-garden-69988
04/18/2022, 4:10 PM