Scheduled jobs with unique

[camaeel]

I'm dynamically inserting jobs into river with ScheduledAt attribute.

It seems from my tests that when I call:

res, err := riverClient.Insert(ctx,
	SomeArgs{}, &river.InsertOpts{
		ScheduledAt: scheduleTime,
		UniqueOpts: river.UniqueOpts{
			ByPeriod: 12 * time.Minute,
		},
	},
)

twice in a loop, second job is treated as violating uniqueness condition and not created. scheduleTime is (of course) different by more than 12 minutes.

Does "Uniqueness" feature check only created time, and dosen't work well with scheduled?

[brandur]

Yeah, it does indeed look like this'll always used the current time. I think it should work to alternatively use scheduled_at. I'll take a crack at it.

[brandur]

Posted a fix for this in #734. It'll go out with the next release.

[camaeel]

@brandur Great, thanx. I will try it when it is released.