### global
[vars]
var qname  = "foo"
### job request
var data = "bar"
var id   = (redis) INCR /job/${qname}/ids/max
(redis) HSET  /job/${qname}/datas ${id} ${data}
(redis) LPUSH /job/${qname}/ids ${id}
### job workers
[dequeue]
var id   = (redis) RPOPLPUSH /job/${qname}/ids /job/${qname}/ids
var data = (redis) HGET /job/${qname}/datas ${id}
(redis) HSET /job/${qname}/locks ${id} ${expiry}
[execute]
(redis) SADD /job/${qname}/done ${id}
          Last active
          February 8, 2022 14:41 
        
      - 
      
- 
        Save maiha/46a6d980c5c6d2fa9b419c168168353d to your computer and use it in GitHub Desktop. 
  
    Sign up for free
    to join this conversation on GitHub.
    Already have an account?
    Sign in to comment