Method WorkBegin

rivertype/river_type.go:369–369

WorkBegin is invoked after a job has been locked and assigned to a particular executor for work and just before the job is actually worked. Returning an error from any HookWorkBegin hook will abort the job early such that it has an error set and doesn't work, with a retry scheduled according to its

(ctx context.Context, job *JobRow)

	// discarded after the function returns. If persistent context needs to be
	// set, middleware should be used instead.
	WorkBegin(ctx context.Context, job *JobRow) error
}

// HookWorkEnd is an interface to a hook that runs after a job has been worked.