Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[BUG] Task chaining does not work inside local execution of a workflow #2374

Closed
2 tasks done
ggydush-fn opened this issue Apr 18, 2022 · 0 comments
Closed
2 tasks done
Assignees
Labels
bug Something isn't working
Milestone

Comments

@ggydush-fn
Copy link

Describe the bug

Running a workflow locally gives a TypeError when using task-chaining syntax.

Expected behavior

Workflow runs locally without error.

Additional context to reproduce

from flytekit import task, workflow


@task
def task_a(x: int) -> int:
    return x


@task
def task_b(x: int) -> int:
    return x


@workflow
def test(x: int) -> int:
    a = task_a(x=x)
    b = task_b(x=x)
    a >> b
    return a


if __name__ == "__main__":
    test(x=1)

Raises:

TypeError: unsupported operand type(s) for >>: 'Promise' and 'Promise'

Screenshots

No response

Are you sure this issue hasn't been raised already?

  • Yes

Have you read the Code of Conduct?

  • Yes
@ggydush-fn ggydush-fn added bug Something isn't working untriaged This issues has not yet been looked at by the Maintainers labels Apr 18, 2022
@kumare3 kumare3 removed the untriaged This issues has not yet been looked at by the Maintainers label Apr 18, 2022
@kumare3 kumare3 added this to the 1.0.1 milestone Apr 18, 2022
@pingsutw pingsutw self-assigned this Apr 26, 2022
@wild-endeavor wild-endeavor modified the milestones: 1.0.1, 1.2.0 Jul 22, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working
Projects
None yet
Development

No branches or pull requests

5 participants