| 1351 | } |
| 1352 | |
| 1353 | type ExecutorTx struct { |
| 1354 | Executor |
| 1355 | |
| 1356 | tx *sql.Tx |
| 1357 | } |
| 1358 | |
| 1359 | func (t *ExecutorTx) Begin(ctx context.Context) (riverdriver.ExecutorTx, error) { |
| 1360 | executorSubTx := &ExecutorSubTx{ |
nothing calls this directly
no outgoing calls
no test coverage detected