diff --git a/engine/cleanupmanager/scheddata.go b/engine/cleanupmanager/scheddata.go index 6c9b1c9ec4..b7307ce245 100644 --- a/engine/cleanupmanager/scheddata.go +++ b/engine/cleanupmanager/scheddata.go @@ -24,12 +24,12 @@ type SchedDataArgs struct { func (SchedDataArgs) Kind() string { return "cleanup-manager-sched-data" } -type SchedDataLookForWorkArgs struct{} +type SchedDataLFW struct{} -func (SchedDataLookForWorkArgs) Kind() string { return "cleanup-manager-sched-data-look-for-work" } +func (SchedDataLFW) Kind() string { return "cleanup-manager-sched-data-lfw" } // LookForWorkScheduleData will automatically look for schedules that need their JSON data cleaned up and insert them into the queue. -func (db *DB) LookForWorkScheduleData(ctx context.Context, j *river.Job[SchedDataLookForWorkArgs]) error { +func (db *DB) LookForWorkScheduleData(ctx context.Context, j *river.Job[SchedDataLFW]) error { cfg := config.FromContext(ctx) if cfg.Maintenance.ScheduleCleanupDays <= 0 { return nil diff --git a/engine/cleanupmanager/setup.go b/engine/cleanupmanager/setup.go index 0251dddd88..e3f3d773d2 100644 --- a/engine/cleanupmanager/setup.go +++ b/engine/cleanupmanager/setup.go @@ -89,7 +89,7 @@ func (db *DB) Setup(ctx context.Context, args processinglock.SetupArgs) error { river.NewPeriodicJob( river.PeriodicInterval(24*time.Hour), func() (river.JobArgs, *river.InsertOpts) { - return SchedDataLookForWorkArgs{}, &river.InsertOpts{ + return SchedDataLFW{}, &river.InsertOpts{ Queue: QueueName, Priority: PriorityTempSchedLFW, }