177
ctx context.Context,
178
filter sqlplugin.VisibilityDeleteFilter,
180
>
defer func() {
181
>
retError = mdb.handle.ConvertError(retError)
182
>
}()
183
>
db, err := mdb.handle.DB()
184
>
if err != nil {
185
return nil, err
186
}
187
189
>
if err != nil {
190
return nil, err
191
}
193
>
err := tx.Rollback()
194
>
// If the error is sql.ErrTxDone, it means the transaction already closed, so ignore error.
195
>
if err != nil && !errors.Is(err, sql.ErrTxDone) {
196
// Transaction rollback error should never happen, unless db connection was lost.
197
retError = fmt.Errorf("transaction rollback failed: %w", retError)
198
}
199
}()
201
>
if err != nil {
202
return nil, fmt.Errorf("unable to delete custom search attributes: %w", err)
203
}
204
>
result, err = tx.NamedExecContext(ctx, templateDeleteWorkflowExecution_v8, filter)
visibility.go
205
>
if err != nil {
206
return nil, fmt.Errorf("unable to delete workflow execution: %w", err)
207
}
209
>
if err != nil {
210
return nil, fmt.Errorf("unable to delete chasm search attributes: %w", err)
211
}
213
>
if err != nil {
214
return nil, err
215
}
217
}
218