Skip to content

Commit d293bac

Browse files
committed
update test
1 parent 8f840c9 commit d293bac

File tree

1 file changed

+12
-2
lines changed

1 file changed

+12
-2
lines changed

dbos/workflows_test.go

Lines changed: 12 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -768,7 +768,12 @@ func TestChildWorkflow(t *testing.T) {
768768
if steps[1].StepName != "DBOS.getResult" {
769769
return "", fmt.Errorf("expected second step name to be getResult, got %s", steps[1].StepName)
770770
}
771-
if steps[1].Output != "from step" {
771+
var stepOutput string
772+
err = json.Unmarshal([]byte(steps[1].Output.(string)), &stepOutput)
773+
if err != nil {
774+
return "", fmt.Errorf("failed to unmarshal step output: %w", err)
775+
}
776+
if stepOutput != "from step" {
772777
return "", fmt.Errorf("expected second step output to be 'from step', got %s", steps[1].Output)
773778
}
774779
if steps[1].Error != nil {
@@ -847,7 +852,12 @@ func TestChildWorkflow(t *testing.T) {
847852
if childWfStep.Output != nil {
848853
return "", fmt.Errorf("expected child wf step output to be nil, got %s", childWfStep.Output)
849854
}
850-
if getResultStep.Output != "from step" {
855+
var stepOutput string
856+
err = json.Unmarshal([]byte(getResultStep.Output.(string)), &stepOutput)
857+
if err != nil {
858+
return "", fmt.Errorf("failed to unmarshal step output: %w", err)
859+
}
860+
if stepOutput != "from step" {
851861
return "", fmt.Errorf("expected get result step output to be 'from step', got %s", getResultStep.Output)
852862
}
853863

0 commit comments

Comments
 (0)