fix: deleteRevKey return haveNoTaskErr (#7)

2024-05-19 23:32:32 +08:00 · 2024-05-19 23:32:32 +08:00 · ac6351386e
parent 9dada0a9b5
commit ac6351386e
1 changed files with 2 additions and 1 deletions
--- a/brokers/etcd/helper.go
+++ b/brokers/etcd/helper.go
@ -22,8 +22,9 @@ func deleteRevKey(ctx context.Context, kv clientv3.KV, key string, rev int64) er
 		return err
 	}

+	// 有写入或者删除竞争
 	if !txnresp.Succeeded {
-		return fmt.Errorf("delete key failed")
+		return fmt.Errorf("delete key failed: %s: %w", key, haveNoTaskErr)
 	}

 	return nil