remove isGetResult

Author: shirzady1934

dbos/system_database.go

@@ -1293,7 +1293,6 @@ type recordOperationResultDBInput struct {
 	tx              pgx.Tx
 	startedAt       time.Time
 	completedAt     time.Time
-	isGetResult     bool
 }
 
 func (s *sysDB) recordOperationResult(ctx context.Context, input recordOperationResultDBInput) error {
@@ -1318,13 +1317,8 @@ func (s *sysDB) recordOperationResult(ctx context.Context, input recordOperation
 		args = append(args, input.childWorkflowID)
 	}
 
-	conflictClause := ""
-	if input.isGetResult {
-		conflictClause = "ON CONFLICT DO NOTHING"
-	}
-
-	query := fmt.Sprintf(`INSERT INTO %s.operation_outputs (%s) VALUES (%s) %s`,
-		pgx.Identifier{s.schema}.Sanitize(), strings.Join(columns, ", "), strings.Join(placeholders, ", "), conflictClause)
+	query := fmt.Sprintf(`INSERT INTO %s.operation_outputs (%s) VALUES (%s)`,
+		pgx.Identifier{s.schema}.Sanitize(), strings.Join(columns, ", "), strings.Join(placeholders, ", "))
 
 	var err error
 	if input.tx != nil {

dbos/workflow.go

@@ -252,7 +252,6 @@ func (h *workflowHandle[R]) processOutcome(outcome workflowOutcome[R], startTime
 			err:             outcome.err,
 			startedAt:       startTime,
 			completedAt:     completedTime,
-			isGetResult:     true,
 			stepName:        "DBOS.getResult",
 		}
 		recordResultErr := retry(h.dbosContext, func() error {
@@ -318,7 +317,6 @@ func (h *workflowPollingHandle[R]) GetResult(opts ...GetResultOption) (R, error)
 				err:             err,
 				startedAt:       startTime,
 				completedAt:     completedTime,
-				isGetResult:     true,
 				stepName:        "DBOS.getResult",
 			}
 			recordResultErr := retry(h.dbosContext, func() error {