JobUpdateTx updates the job with the given ID. If JobUpdateParams.Output is not set, this function may be used inside a job work function to set a job's output based on output recorded so far using RecordOutput. This variant updates the job inside of a transaction.
(ctx context.Context, tx TTx, id int64, params *JobUpdateParams)
| 1631 | // |
| 1632 | // This variant updates the job inside of a transaction. |
| 1633 | func (c *Client[TTx]) JobUpdateTx(ctx context.Context, tx TTx, id int64, params *JobUpdateParams) (*rivertype.JobRow, error) { |
| 1634 | return c.jobUpdate(ctx, c.driver.UnwrapExecutor(tx), id, params) |
| 1635 | } |
| 1636 | |
| 1637 | func (c *Client[TTx]) jobUpdate(ctx context.Context, exec riverdriver.Executor, id int64, params *JobUpdateParams) (*rivertype.JobRow, error) { |
| 1638 | if params == nil { |