Greg Gydush
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!from 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'
Kevin Su
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)
Greg Gydush
04/18/2022, 4:06 PMJay Ganbat
04/18/2022, 4:06 PMcreate_node
works within the workflow locally, though not very elegant compared to >>
Ketan (kumare3)
Greg Gydush
04/18/2022, 4:10 PM