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

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