Method JobRetry

riverdriver/riversqlite/river_sqlite_driver.go:697–726

(ctx context.Context, params *riverdriver.JobRetryParams)

}

func (e *Executor) JobRetry(ctx context.Context, params *riverdriver.JobRetryParams) (*rivertype.JobRow, error) {
	// Unlike Postgres, this must be carried out in two operations because
	// SQLite doesn't support CTEs containing `UPDATE`. As long as the job
	// exists and is not running, only one database operation is needed, but if
	// the initial update comes back empty, it does one more fetch to return the
	// most appropriate error.
	return dbutil.WithTxV(ctx, e, func(ctx context.Context, execTx riverdriver.ExecutorTx) (*rivertype.JobRow, error) {
		dbtx := templateReplaceWrapper{dbtx: e.driver.UnwrapTx(execTx), replacer: &e.driver.replacer}

		job, err := dbsqlc.New().JobRetry(schemaTemplateParam(ctx, params.Schema), dbtx, &dbsqlc.JobRetryParams{
			ID:  params.ID,
			Now: timeStringNullable(params.Now),
		})
		if err != nil {
			if errors.Is(err, sql.ErrNoRows) {
				job, err := execTx.JobGetByID(ctx, &riverdriver.JobGetByIDParams{
					ID:     params.ID,
					Schema: params.Schema,
				})
				if err != nil {
					return nil, interpretError(err)
				}
				return job, nil
			}

			return nil, interpretError(err)
		}
		return jobRowFromInternal(job)
	})
}

func (e *Executor) JobSchedule(ctx context.Context, params *riverdriver.JobScheduleParams) ([]*riverdriver.JobScheduleResult, error) {
	// This operation diverges the most from the Postgres version out of all the