https://flyte.org logo
#ask-the-community
Title
# ask-the-community
l

Laura Lin

11/14/2022, 6:38 PM
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'
s

Samhita Alla

11/14/2022, 6:46 PM
Should be supported. Could you share what
z
and
x
are?
l

Laura Lin

11/14/2022, 7:07 PM
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'
y

Yee

11/14/2022, 9:17 PM
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?
l

Laura Lin

11/14/2022, 9:36 PM
yep.
@Yee is there a github issue I can follow?
y

Yee

11/14/2022, 9:37 PM
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)
hope to merge soon
3 Views