uneeded warning

Author: maxdml

dbos/system_database.go

@@ -1189,17 +1189,16 @@ func (s *sysDB) recordOperationResult(ctx context.Context, input recordOperation
 		return fmt.Errorf("failed to serialize output: %w", err)
 	}
 
-	var commandTag pgconn.CommandTag
 	if input.tx != nil {
-		commandTag, err = input.tx.Exec(ctx, query,
+		_, err = input.tx.Exec(ctx, query,
 			input.workflowID,
 			input.stepID,
 			outputString,
 			errorString,
 			input.stepName,
 		)
 	} else {
-		commandTag, err = s.pool.Exec(ctx, query,
+		_, err = s.pool.Exec(ctx, query,
 			input.workflowID,
 			input.stepID,
 			outputString,
@@ -1208,12 +1207,6 @@ func (s *sysDB) recordOperationResult(ctx context.Context, input recordOperation
 		)
 	}
 
-	/*
-		s.logger.Debug("RecordOperationResult CommandTag", "command_tag", commandTag)
-		s.logger.Debug("RecordOperationResult Rows affected", "rows_affected", commandTag.RowsAffected())
-		s.logger.Debug("RecordOperationResult SQL", "sql", commandTag.String())
-	*/
-
 	if err != nil {
 		s.logger.Error("RecordOperationResult Error occurred", "error", err)
 		if pgErr, ok := err.(*pgconn.PgError); ok && pgErr.Code == _PG_ERROR_UNIQUE_VIOLATION {
@@ -1222,10 +1215,6 @@ func (s *sysDB) recordOperationResult(ctx context.Context, input recordOperation
 		return err
 	}
 
-	if commandTag.RowsAffected() == 0 {
-		s.logger.Warn("RecordOperationResult No rows were affected by the insert")
-	}
-
 	return nil
 }