numerous-hamburger-7178
11/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'
tall-lock-23197
z
and x
are?numerous-hamburger-7178
11/14/2022, 7:07 PMfrom 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())
numerous-hamburger-7178
11/14/2022, 7:07 PMline 24, in xf
z >> x
TypeError: unsupported operand type(s) for >>: 'str' and 'str'
thankful-minister-83577
thankful-minister-83577
thankful-minister-83577
numerous-hamburger-7178
11/14/2022, 9:36 PMnumerous-hamburger-7178
11/14/2022, 9:37 PMthankful-minister-83577
thankful-minister-83577
thankful-minister-83577
thankful-minister-83577
thankful-minister-83577