Skip to content

Commit 8c8f152

Browse files
committed
have special steps pass recordOperationResult through
1 parent 0a554c6 commit 8c8f152

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

dbos/system_database.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1767,7 +1767,7 @@ func (s *sysDB) send(ctx context.Context, input WorkflowSendInput) error {
17671767

17681768
err = s.recordOperationResult(ctx, recordInput)
17691769
if err != nil {
1770-
return fmt.Errorf("failed to record operation result: %w", err)
1770+
return err
17711771
}
17721772
}
17731773

@@ -1921,7 +1921,7 @@ func (s *sysDB) recv(ctx context.Context, input recvInput) (any, error) {
19211921
}
19221922
err = s.recordOperationResult(ctx, recordInput)
19231923
if err != nil {
1924-
return nil, fmt.Errorf("failed to record operation result: %w", err)
1924+
return nil, err
19251925
}
19261926

19271927
if err := tx.Commit(ctx); err != nil {
@@ -2002,7 +2002,7 @@ func (s *sysDB) setEvent(ctx context.Context, input WorkflowSetEventInput) error
20022002

20032003
err = s.recordOperationResult(ctx, recordInput)
20042004
if err != nil {
2005-
return fmt.Errorf("failed to record operation result: %w", err)
2005+
return err
20062006
}
20072007

20082008
// Commit transaction
@@ -2134,7 +2134,7 @@ func (s *sysDB) getEvent(ctx context.Context, input getEventInput) (any, error)
21342134

21352135
err = s.recordOperationResult(ctx, recordInput)
21362136
if err != nil {
2137-
return nil, fmt.Errorf("failed to record operation result: %w", err)
2137+
return nil, err
21382138
}
21392139
}
21402140

0 commit comments

Comments
 (0)