-
Notifications
You must be signed in to change notification settings - Fork 99
Honor all non-terminal commands #776
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
Conversation
581ee86
to
f8af5e7
Compare
f8af5e7
to
d2bb28b
Compare
7de4dfd
to
1d2cfc0
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Looking good to me. Just needs the unit tests to test dealing with flag being present or not in old history, and integ test like you said.
f333634
to
87ac411
Compare
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks Dan!
async fn _do_post_terminal_commands_test( | ||
commands_sent_by_lang: Vec<workflow_command::Variant>, | ||
response_types: impl IntoIterator<Item = impl Into<ResponseType>>, | ||
expected_command_types: Option<Vec<CommandType>>, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
nit: Doesn't need to be an option, can just be empty vec when None
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think option is a reasonable choice: None
is being used to mean the concept of expected commands is irrelevant, since the worker is purely replaying all history and will never emit a WFT task response; that's as opposed to Some(empty_vec)
which would mean SDK did a non-replay WFT but replied without any commands (e.g. all coroutines are blocked on a workflow condition; also WFT fail might be represented like that). But lmk if that doesn't make sense; happy to change if so.
8ba0fd7
to
24d23a8
Compare
Fixes #778
Evidence this is correct
core