Merge benmanns/goworker#85 #3

Mentioning the 1.4 that we'll create is based on master, as the last release is 1.3 and it's old

This logic is ported from the Ruby. It allows each worker to heartbeat Redis so if everything is killed instead of keeping them on the DB it'll try to prun them after a while (5'). The only logic ont ported from Ruby is the one about checking the PID.

Otherwise it cannot be imported from the outseide

When redis returns nil they return an error with an specific logic to check it with

…ss fully closed It's useful when you want to exactly know when the worker has fully stopped and cleaned. This can be useful in cases in which you have to block something until the worker is closed for example if the worker is in goroutines and the main process is killed you could end up with workers not beeing cleaned so using this function would avoid this.

This option is useful to automatically remove retried failed jobs from the 'failed' queue that exceede that duration, this check will be done every 1m. Also changed the 'failed.FailedAt' and added 'failed.RetriedAt' and switched them to type string. The main reason is that the Ruby lib is setting those values in an specific format and Ruby can read multiple formats into one, but GO cannot and we need to actually use the same ones or the unmarshaler does not work so I decided to switch them to 'string' and add helpers to set/get the values that will directly convert them. All the logic has more or less been ported from the Ruby version, on how to remove failed jobs and how the data is stored, as the 'MaxAgeRetries' is something unique from this GO version

This will remove workers thare could be stuck but it's not backwards compatible if enabled

For some reason with previous tests this was not found but now it's fixed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Merge benmanns/goworker#85 #3

Merge benmanns/goworker#85 #3

Commits on Jul 26, 2022