Sha256: 5401325f75e4d760f6d1eadeb10e8a9af36363ecd85907da15476f380e20b447
Contents?: true
Size: 623 Bytes
Versions: 3
Compression:
Stored size: 623 Bytes
Contents
-- Remove job from reliability queue redis.call("LREM", KEYS[2], 0, ARGV[3]) redis.call("ZREM", KEYS[3], ARGV[3]) -- Add job and its fail time (score) to failed sorted set redis.call("ZADD", KEYS[1], ARGV[1], ARGV[2]) -- Remove all related workflow keys local keys = redis.call("SMEMBERS", KEYS[4]) redis.call("DEL", KEYS[4], KEYS[5], KEYS[6], KEYS[7], unpack(keys)) -- Remove any jobs that have been given up long enough ago (their score is -- below given value) and make sure the number of jobs is capped redis.call("ZREMRANGEBYSCORE", KEYS[1], "-inf", ARGV[4]) redis.call("ZREMRANGEBYRANK", KEYS[1], 0, -ARGV[5] - 1)
Version data entries
3 entries across 3 versions & 1 rubygems
Version | Path |
---|---|
pallets-0.11.0 | lib/pallets/backends/scripts/give_up.lua |
pallets-0.10.0 | lib/pallets/backends/scripts/give_up.lua |
pallets-0.9.0 | lib/pallets/backends/scripts/give_up.lua |