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

feat: support parallel step execution #58

Open
abelanger5 opened this issue Jan 2, 2024 · 1 comment
Open

feat: support parallel step execution #58

abelanger5 opened this issue Jan 2, 2024 · 1 comment

Comments

@abelanger5
Copy link
Contributor

It's necessary to support steps which can:

  1. Execute the same step with different inputs in parallel.
  2. Execute different steps with the same input in parallel.

From a client perspective, the Go SDK should be able to detect parallel steps based on the output from a previous step and the input to the current step. For example, if one step has the following output:

func stepOne(ctx context.Context) ([]stepOneOutput, error)

And the second step has the following input:

func stepTwo(ctx context.Context, in *stepOneOutput) error

Then stepTwo should be run for each array element resulting from stepOne.

@abelanger5
Copy link
Contributor Author

Partially fixed by #108, particularly:

Execute different steps with the same input in parallel.

For Execute the same step with different inputs in parallel, we are still working on scatter/gather workflows.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant