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

29 Mar 2021

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
-- 
2.23.0

    

Cao Xueliang