Are `>>` operators (to explicitly chain task...
# flyte-support
n
Are
>>
operators (to explicitly chain tasks) supported for dynamic workflows when running locally? either thru python or pyflyte run. It seems like its not being overridden. When I run it from the Flyte console, it doesn't throw any errors though.
Copy code
z >> x
TypeError: unsupported operand type(s) for >>: 'str' and 'DataFrame'
t
Should be supported. Could you share what
z
and
x
are?
n
Copy code
from flytekit import task, workflow, dynamic


@task()
def test(s: str) -> str:
    return s


@task()
def test2(s: str) -> str:
    return s


@dynamic
def xf():
    z = test(s="yo")
    x = test2(s="test2")
    z >> x
    return x

@workflow
def wf():
    return xf()


if __name__ == "__main__":
    print(wf())
here's an example where I get
Copy code
line 24, in xf
    z >> x
TypeError: unsupported operand type(s) for >>: 'str' and 'str'
t
we are working on this actually. this is a known bug.
will have an issue written up and hopefully a fix later in the week.
i assume you’re seeing this in local execution?
n
yep.
@thankful-minister-83577 is there a github issue I can follow?
t
not yet
we’ll try to make one.
(we will make one… it’s just that it’s one of those where by the time you figure out how to write a nice ticket, you’ve already fixed it)
👍 1
hope to merge soon
155 Views