[PATCH compass-ci] src/lib: add default prefix for move queue

26 Mar 2021

Signed-off-by: Cao Xueliang <caoxl78320@163.com>
---
 src/lib/etcd_client.cr | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/lib/etcd_client.cr b/src/lib/etcd_client.cr
index 637b738..7891eb3 100644
--- a/src/lib/etcd_client.cr
+++ b/src/lib/etcd_client.cr
@@ -39,6 +39,8 @@ class EtcdClient
   end
 
   def move(f_queue, t_queue, value)
+    f_queue = "#{BASE}/#{f_queue}" unless f_queue.starts_with?(BASE)
+    t_queue = "#{BASE}/#{t_queue}" unless t_queue.starts_with?(BASE)
     @etcd.kv.move(f_queue, t_queue, value)
   end
 
-- 
2.23.0

    

Cao Xueliang