fix: minor tweaks

monkeyDluffy6017 · Dec 8, 2023 · 9b03f2b · 9b03f2b
1 parent 09dcb3b
commit 9b03f2b
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/apisix/core/config_etcd.lua b/apisix/core/config_etcd.lua
@@ -288,6 +288,9 @@ local function run_watch(premature)
 
     if not exiting() then
         ngx_timer_at(0, run_watch)
+    else
+        -- notify child watchers
+        produce_res(nil, "worker exited")
     end
 end
 
@@ -843,6 +846,9 @@ local function _automatic_fetch(premature, self)
                                        .. backoff_duration .. "s")
                         end
                     end
+                elseif err == "worker exited" then
+                    log.info("worker exited.")
+                    return
                 elseif err ~= "timeout" and err ~= "Key not found"
                     and self.last_err ~= err then
                     log.error("failed to fetch data from etcd: ", err, ", ",