Skip to content

Commit 004fcec

Browse files
authored
Fix bug with workflow shadower: ALL is documented as an allowed Status; test and fix. (#1187)
1 parent 3a730da commit 004fcec

File tree

2 files changed

+37
-1
lines changed

2 files changed

+37
-1
lines changed

internal/query_builder.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,7 @@ func ToWorkflowStatus(statusString string) (WorkflowStatus, error) {
155155
switch status {
156156
case WorkflowStatusOpen, WorkflowStatusClosed, WorkflowStatusCompleted,
157157
WorkflowStatusFailed, WorkflowStatusCanceled, WorkflowStatusTerminated,
158-
WorkflowStatusContinuedAsNew, WorkflowStatusTimedOut:
158+
WorkflowStatusContinuedAsNew, WorkflowStatusTimedOut, WorkflowStatusALL:
159159
return status, nil
160160
default:
161161
return "", fmt.Errorf("unknown workflow status: %v", statusString)

internal/query_builder_test.go

Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -199,6 +199,42 @@ func (s *queryBuilderSuite) TestToWorkflowStatus() {
199199
expectErr: false,
200200
expectedStatus: WorkflowStatusTerminated,
201201
},
202+
{
203+
msg: "all",
204+
statusString: "ALL",
205+
expectErr: false,
206+
expectedStatus: WorkflowStatusALL,
207+
},
208+
{
209+
msg: "closed",
210+
statusString: "CLOSED",
211+
expectErr: false,
212+
expectedStatus: WorkflowStatusClosed,
213+
},
214+
{
215+
msg: "failed",
216+
statusString: "FAILED",
217+
expectErr: false,
218+
expectedStatus: WorkflowStatusFailed,
219+
},
220+
{
221+
msg: "completed",
222+
statusString: "COMPLETED",
223+
expectErr: false,
224+
expectedStatus: WorkflowStatusCompleted,
225+
},
226+
{
227+
msg: "canceled",
228+
statusString: "CANCELED",
229+
expectErr: false,
230+
expectedStatus: WorkflowStatusCanceled,
231+
},
232+
{
233+
msg: "continued as new",
234+
statusString: "CONTINUED_AS_NEW",
235+
expectErr: false,
236+
expectedStatus: WorkflowStatusContinuedAsNew,
237+
},
202238
}
203239

204240
for _, test := range testCases {

0 commit comments

Comments
 (0)