https://flyte.org
Join Slack
Happy Monday y’all! Was curious if the `>>` could be supported locally - I tried running a loc...
# flytekit
r
Happy Monday y’all! Was curious if the 
>>
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!
Copy code
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:
Copy code
TypeError: unsupported operand type(s) for >>: 'Promise' and 'Promise'
g
Yeah, you can do that in the task instead of workflow. For example,
Copy code
@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)
r
m
create_node
works within the workflow locally, though not very elegant compared to 
>>
f
yes this should work locally
this is a bug
cc @thankful-minister-83577 / @high-accountant-32689
can you please file it @rich-garden-69988
👍 1
r
164 Views
Open in Slack
PreviousNext
Powered by

Flyte

Flyte enables production-grade orchestration for machine learning workflows and data processing created to accelerate local workflows to production.

Powered by