Method TryCloseSlot

internal/jobexecutor/job_executor.go:138–140

TryCloseSlot marks this executor's producer slot as closed. A closed slot means the producer has already stopped counting this executor against its active worker capacity, although the executor goroutine may still be running. It returns true only the first time the slot is closed.

()

// active worker capacity, although the executor goroutine may still be running.
// It returns true only the first time the slot is closed.
func (e *JobExecutor) TryCloseSlot() bool {
	return e.slotClosed.CompareAndSwap(false, true)
}

func (e *JobExecutor) Cancel(ctx context.Context) {
	e.Logger.WarnContext(ctx, e.Name+": job cancelled remotely", slog.Int64("job_id", e.JobRow.ID))