Method JobGetStuck

riverdriver/riversqlite/river_sqlite_driver.go:518–527

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

}

func (e *Executor) JobGetStuck(ctx context.Context, params *riverdriver.JobGetStuckParams) ([]*rivertype.JobRow, error) {
	jobs, err := dbsqlc.New().JobGetStuck(schemaTemplateParam(ctx, params.Schema), e.dbtx, &dbsqlc.JobGetStuckParams{
		Max:          int64(params.Max),
		StuckHorizon: timeString(params.StuckHorizon),
	})
	if err != nil {
		return nil, interpretError(err)
	}
	return sliceutil.MapError(jobs, jobRowFromInternal)
}

func (e *Executor) JobInsertFastMany(ctx context.Context, params *riverdriver.JobInsertFastManyParams) ([]*riverdriver.JobInsertFastResult, error) {
	// We use a special `(xmax != 0)` trick in Postgres to determine whether an