river
river copied to clipboard
riverqueue
Fast and reliable background jobs in Go
Just one I noticed while trying to implement a middleware that does encryption. Here's some lines from the test suite that show roughly what it's like to use this middleware:...
Hello there! After reading about leader election, updating timestamps, my initial thought was that rescuer would also monitor all workers that have running jobs attached to them. I assumed that...
I've seen a bunch of these in the last few days: https://github.com/riverqueue/river/actions/runs/13346849278/job/37278355065?pr=760 ``` --- FAIL: TestDriverRiverPgxV5 (33.34s) --- FAIL: TestDriverRiverPgxV5/GetMigrationLines ([10](https://github.com/riverqueue/river/actions/runs/13346849278/job/37278355065?pr=760#step:7:11).00s) riverdrivertest.go:55: Failed to acquire pool for test DB: context...
While reading through the executor for another change, I realized that as of #632 / #584 we're applying the job timeout _after_ stepping through all the middleware: https://github.com/riverqueue/river/blob/fc667eb33b2427f28ca335f5287610edaa2b7e93/job_executor.go#L209-L227 I'm not...
I'm completely new to River and immediately ran into the following issue when playing with the examples against Pg 16.4: ``` msg="Elector: Error attempting to elect" err="ERROR: cannot cast type...
Would be nice to have a simple solution for ephemeral jobs that don't need to be stored in the database after completion. The retention mechanism works well, however, it is...
I am running the river on windows, but when start the client, it's stucking. Here are logs that I am getting, but it's still stucking. My Windows Spec: Windows 11...
We haven't done a release in a while, so here prepare v0.27.0 to go out the door with the last few months worth of changes and bug fixes. [skip ci]
I have these two payloads that I'm passing into river, and because of my custom uniqueness constraints, I don't want to be adding both of them in. But it still...
This is once again in pursuit of solving a particular user's use case. We currently have mechanisms that to add and remove periodic jobs to a client, but these functions...