[Compass-ci] [PATCH compass-ci 7/7] scheduler: add get_new_seqno in redis client

Signed-off-by: Cao Xueliang caoxl78320@163.com --- src/scheduler/redis_client.cr | 4 ++++ 1 file changed, 4 insertions(+)

diff --git a/src/scheduler/redis_client.cr b/src/scheduler/redis_client.cr index 030d1b7..ed2af6e 100644 --- a/src/scheduler/redis_client.cr +++ b/src/scheduler/redis_client.cr @@ -70,4 +70,8 @@ class Redis::Client def remove_finished_job(job_id : String) @client.hdel("sched/id2job", job_id) end + + def get_new_seqno + return @client.incr("#{QUEUE_NAME_BASE}/seqno") + end end