Skip to content

Commit f2bbb60

Browse files
committed
Fix: Update
1 parent 14fe7cb commit f2bbb60

File tree

2 files changed

+5
-7
lines changed

2 files changed

+5
-7
lines changed

dbos/system_database.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -732,17 +732,17 @@ func (s *sysDB) listWorkflows(ctx context.Context, input listWorkflowsDBInput) (
732732
scanArgs = append(scanArgs, &inputString)
733733
}
734734

735+
err := rows.Scan(scanArgs...)
736+
if err != nil {
737+
return nil, fmt.Errorf("failed to scan workflow row: %w", err)
738+
}
739+
735740
if authenticatedRoles != nil && *authenticatedRoles != "" {
736741
if err := json.Unmarshal([]byte(*authenticatedRoles), &wf.AuthenticatedRoles); err != nil {
737742
return nil, fmt.Errorf("failed to unmarshal authenticated_roles: %w", err)
738743
}
739744
}
740745

741-
err := rows.Scan(scanArgs...)
742-
if err != nil {
743-
return nil, fmt.Errorf("failed to scan workflow row: %w", err)
744-
}
745-
746746
if queueName != nil && len(*queueName) > 0 {
747747
wf.QueueName = *queueName
748748
}

dbos/workflows_test.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@ import (
44
"context"
55
"errors"
66
"fmt"
7-
"log"
87
"reflect"
98
"runtime"
109
"sync"
@@ -4147,7 +4146,6 @@ func TestWorkflowIdentity(t *testing.T) {
41474146

41484147
// Retrieve the workflow's status.
41494148
status, err := handle.GetStatus()
4150-
log.Print(status)
41514149
require.NoError(t, err)
41524150

41534151
t.Run("CheckAuthenticatedUser", func(t *testing.T) {

0 commit comments

Comments
 (0)