Skip to content

Commit

Permalink
IWF-472: Adding required parameter for panic utils
Browse files Browse the repository at this point in the history
  • Loading branch information
samuel27m committed Jan 24, 2025
1 parent 975a925 commit 9640c0c
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 7 deletions.
2 changes: 1 addition & 1 deletion integ/set_search_attributes_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -94,7 +94,7 @@ func TestSetSearchAttributes(t *testing.T) {
ValueType: ptr.Any(iwfidl.KEYWORD_ARRAY),
},
}}).Execute()
panicAtHttpError(err, httpRespGet)
panicAtHttpError(err, httpRespGet, t)

assertions.ElementsMatch(signalVals, searchResult.SearchAttributes)
}
12 changes: 6 additions & 6 deletions integ/wait_until_search_attributes_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -80,14 +80,14 @@ func doTestWaitUntilSearchAttributes(

switch mode := config.GetExecutingStateIdMode(); mode {
case iwfidl.ENABLED_FOR_ALL:
assertSearch(fmt.Sprintf("WorkflowId='%v'", wfId), 1, apiClient, assertions)
assertSearch(fmt.Sprintf("WorkflowId='%v' AND %v='%v'", wfId, wait_until_search_attributes.TestSearchAttributeExecutingStateIdsKey, wait_until_search_attributes.State2), 1, apiClient, assertions)
assertSearch(t, fmt.Sprintf("WorkflowId='%v'", wfId), 1, apiClient, assertions)
assertSearch(t, fmt.Sprintf("WorkflowId='%v' AND %v='%v'", wfId, wait_until_search_attributes.TestSearchAttributeExecutingStateIdsKey, wait_until_search_attributes.State2), 1, apiClient, assertions)
case iwfidl.ENABLED_FOR_STATES_WITH_WAIT_UNTIL:
assertSearch(fmt.Sprintf("WorkflowId='%v'", wfId), 1, apiClient, assertions)
assertSearch(fmt.Sprintf("WorkflowId='%v' AND %v='%v'", wfId, wait_until_search_attributes.TestSearchAttributeExecutingStateIdsKey, wait_until_search_attributes.State2), 0, apiClient, assertions)
assertSearch(t, fmt.Sprintf("WorkflowId='%v'", wfId), 1, apiClient, assertions)
assertSearch(t, fmt.Sprintf("WorkflowId='%v' AND %v='%v'", wfId, wait_until_search_attributes.TestSearchAttributeExecutingStateIdsKey, wait_until_search_attributes.State2), 0, apiClient, assertions)
case iwfidl.DISABLED:
assertSearch(fmt.Sprintf("WorkflowId='%v'", wfId), 1, apiClient, assertions)
assertSearch(fmt.Sprintf("WorkflowId='%v' AND %v='%v'", wfId, wait_until_search_attributes.TestSearchAttributeExecutingStateIdsKey, wait_until_search_attributes.State2), 0, apiClient, assertions)
assertSearch(t, fmt.Sprintf("WorkflowId='%v'", wfId), 1, apiClient, assertions)
assertSearch(t, fmt.Sprintf("WorkflowId='%v' AND %v='%v'", wfId, wait_until_search_attributes.TestSearchAttributeExecutingStateIdsKey, wait_until_search_attributes.State2), 0, apiClient, assertions)
}

reqWait := apiClient.DefaultApi.ApiV1WorkflowGetWithWaitPost(context.Background())
Expand Down

0 comments on commit 9640c0c

Please sign in to comment.