Skip to content

Conversation

@Col-Waltz
Copy link

This PR synchronizes sharded-queue with sharded-queue-ee with cherry-picks of all features added to sharded-queue-ee. Transition to self-hosted runners and all CI work made on sharded-queue-ee repository is skipped.

Closes TNTP-4066.

Added 'release_limit' configuration option.
A taken task is removed from the queue if the task
has been released (by `release` or `ttr`) `release_limit` times.

Closes #8
Added 'release_limit_policy' option to all drivers
to control the behavior when a task reached the release_limit:

'release_limit_policy = nil' or 'release_limit_policy = DELETE' - the task is deleted.
'release_limit_policy = DLQ' - the task is moved to the dead letter queue.

Closes #9
Moved common code for 'put' functions into new function.
['sharded_queue.roles'] = 'sharded_queue/roles.lua',
['sharded_queue.stash'] = 'sharded_queue/stash.lua',
['sharded_queue.state'] = 'sharded_queue/state.lua',
['sharded_queue.consts'] = 'sharded_queue/consts.lua',
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The new file is missed.

Suggested change
['sharded_queue.consts'] = 'sharded_queue/consts.lua',
['sharded_queue.consts'] = 'sharded_queue/consts.lua',
['sharded_queue.dlq'] = 'sharded_queue/dlq.lua',

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants