| 1042 | } |
| 1043 | |
| 1044 | type ExecutorTx struct { |
| 1045 | Executor |
| 1046 | |
| 1047 | tx *sql.Tx |
| 1048 | } |
| 1049 | |
| 1050 | func (t *ExecutorTx) Begin(ctx context.Context) (riverdriver.ExecutorTx, error) { |
| 1051 | return (&ExecutorSubTx{ |
nothing calls this directly
no outgoing calls
no test coverage detected