Laura Lin11/14/2022, 6:38 PM
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.
z >> x TypeError: unsupported operand type(s) for >>: 'str' and 'DataFrame'
Laura Lin11/14/2022, 7:07 PM
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())
line 24, in xf z >> x TypeError: unsupported operand type(s) for >>: 'str' and 'str'
Laura Lin11/14/2022, 9:36 PM