Method JobUpdate

riverdriver/riversqlite/river_sqlite_driver.go:906–922

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

}

func (e *Executor) JobUpdate(ctx context.Context, params *riverdriver.JobUpdateParams) (*rivertype.JobRow, error) {
	metadata := params.Metadata
	if metadata == nil {
		metadata = []byte("{}")
	}

	job, err := dbsqlc.New().JobUpdate(schemaTemplateParam(ctx, params.Schema), e.dbtx, &dbsqlc.JobUpdateParams{
		ID:              params.ID,
		MetadataDoMerge: params.MetadataDoMerge,
		Metadata:        metadata,
	})
	if err != nil {
		return nil, interpretError(err)
	}

	return jobRowFromInternal(job)
}

func (e *Executor) JobUpdateFull(ctx context.Context, params *riverdriver.JobUpdateFullParams) (*rivertype.JobRow, error) {
	attemptedAt := params.AttemptedAt