Method JobUpdateFull

riverdriver/riversqlite/river_sqlite_driver.go:924–974

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

}

func (e *Executor) JobUpdateFull(ctx context.Context, params *riverdriver.JobUpdateFullParams) (*rivertype.JobRow, error) {
	attemptedAt := params.AttemptedAt
	if attemptedAt != nil {
		attemptedAt = ptrutil.Ptr(attemptedAt.UTC())
	}

	attemptedBy, err := json.Marshal(params.AttemptedBy)
	if err != nil {
		return nil, err
	}

	errors, err := json.Marshal(sliceutil.Map(params.Errors, func(e []byte) json.RawMessage { return json.RawMessage(e) }))
	if err != nil {
		return nil, err
	}

	finalizedAt := params.FinalizedAt
	if finalizedAt != nil {
		finalizedAt = ptrutil.Ptr(finalizedAt.UTC())
	}

	metadata := params.Metadata
	if metadata == nil {
		metadata = []byte("{}")
	}

	job, err := dbsqlc.New().JobUpdateFull(schemaTemplateParam(ctx, params.Schema), e.dbtx, &dbsqlc.JobUpdateFullParams{
		ID:                  params.ID,
		Attempt:             int64(params.Attempt),
		AttemptDoUpdate:     params.AttemptDoUpdate,
		AttemptedAt:         attemptedAt,
		AttemptedAtDoUpdate: params.AttemptedAtDoUpdate,
		AttemptedBy:         attemptedBy,
		AttemptedByDoUpdate: params.AttemptedByDoUpdate,
		ErrorsDoUpdate:      params.ErrorsDoUpdate,
		Errors:              errors,
		FinalizedAtDoUpdate: params.FinalizedAtDoUpdate,
		FinalizedAt:         finalizedAt,
		MaxAttemptsDoUpdate: params.MaxAttemptsDoUpdate,
		MaxAttempts:         int64(min(params.MaxAttempts, math.MaxInt64)),
		MetadataDoUpdate:    params.MetadataDoUpdate,
		Metadata:            metadata,
		StateDoUpdate:       params.StateDoUpdate,
		State:               string(params.State),
	})
	if err != nil {
		return nil, interpretError(err)
	}

	return jobRowFromInternal(job)
}

func (e *Executor) LeaderAttemptElect(ctx context.Context, params *riverdriver.LeaderElectParams) (*riverdriver.Leader, error) {
	leader, err := dbsqlc.New().LeaderAttemptElect(schemaTemplateParam(ctx, params.Schema), e.dbtx, &dbsqlc.LeaderAttemptElectParams{