diff --git a/etcd.go b/etcd.go index f589a01..6f99795 100644 --- a/etcd.go +++ b/etcd.go @@ -40,5 +40,5 @@ func (e Etcd) GetWatchKey() string { // IssueWatchKey 下发的key func (e Etcd) IssueWatchKey(ip string) string { - return JobSaveDir + ip + "/" + return JobSaveDir + ip } diff --git a/etcd_worker.go b/etcd_worker.go index 295325f..3558a6b 100644 --- a/etcd_worker.go +++ b/etcd_worker.go @@ -100,6 +100,7 @@ func (e Etcd) RegisterWorker() { } RETRY: + log.Println("异常 RETRY ", regKey) time.Sleep(1 * time.Second) if cancelFunc != nil { cancelFunc() diff --git a/version.go b/version.go index c4b33b2..5c17e6c 100644 --- a/version.go +++ b/version.go @@ -1,3 +1,3 @@ package gojobs -const Version = "1.0.13" +const Version = "1.0.14"