acoustic-carpenter-78188
07/28/2023, 9:48 PM@task
def test(x: int) -> int:
return x + 1
@task
def echo_integer(value: int) -> int:
logging.error(f"I've got value {value}")
return test(x=value + 5) + 1
@workflow
def wf(
value: int,
):
return echo_integer(value=value)
Expected behavior
The above code should work when run locally
edit: flytekit should also log a warning saying that the inner task is executed as a function and not an atomic entity
Additional context to reproduce
No response
Screenshots
No response
Are you sure this issue hasn't been raised already?
☑︎ Yes
Have you read the Code of Conduct?
☑︎ Yes
flyteorg/flyteacoustic-carpenter-78188
07/28/2023, 9:48 PM