@@ -54,6 +54,7 @@ const markGatewayDraining = vi.fn();
|
54 | 54 | const waitForActiveTasks = vi.fn(async (_timeoutMs?: number) => ({ drained: true })); |
55 | 55 | const resetAllLanes = vi.fn(); |
56 | 56 | const reloadTaskRegistryFromStore = vi.fn(); |
| 57 | +const clearRuntimeConfigSnapshot = vi.fn(); |
57 | 58 | const restartGatewayProcessWithFreshPid = vi.fn< |
58 | 59 | (_opts?: { env?: NodeJS.ProcessEnv }) => { |
59 | 60 | mode: "spawned" | "supervised" | "disabled" | "failed"; |
@@ -152,6 +153,10 @@ vi.mock("../../tasks/runtime-internal.js", () => ({
|
152 | 153 | reloadTaskRegistryFromStore: () => reloadTaskRegistryFromStore(), |
153 | 154 | })); |
154 | 155 | |
| 156 | +vi.mock("../../config/runtime-snapshot.js", () => ({ |
| 157 | +clearRuntimeConfigSnapshot: () => clearRuntimeConfigSnapshot(), |
| 158 | +})); |
| 159 | + |
155 | 160 | vi.mock("../../tasks/task-registry.maintenance.js", () => ({ |
156 | 161 | getInspectableActiveTaskRestartBlockers: () => getInspectableActiveTaskRestartBlockers(), |
157 | 162 | })); |
@@ -787,6 +792,7 @@ describe("runGatewayLoop", () => {
|
787 | 792 | expectRestartCloseCall(closeFirst, 1_234); |
788 | 793 | expect(markGatewaySigusr1RestartHandled).toHaveBeenCalledTimes(1); |
789 | 794 | expect(resetAllLanes).toHaveBeenCalledTimes(1); |
| 795 | +expect(clearRuntimeConfigSnapshot).toHaveBeenCalledTimes(1); |
790 | 796 | expect(resetGatewayRestartStateForInProcessRestart).toHaveBeenCalledTimes(1); |
791 | 797 | expect(reloadTaskRegistryFromStore).toHaveBeenCalledTimes(1); |
792 | 798 | |
@@ -798,6 +804,7 @@ describe("runGatewayLoop", () => {
|
798 | 804 | expect(markGatewaySigusr1RestartHandled).toHaveBeenCalledTimes(2); |
799 | 805 | expect(markGatewayDraining).toHaveBeenCalledTimes(2); |
800 | 806 | expect(resetAllLanes).toHaveBeenCalledTimes(2); |
| 807 | +expect(clearRuntimeConfigSnapshot).toHaveBeenCalledTimes(2); |
801 | 808 | expect(resetGatewayRestartStateForInProcessRestart).toHaveBeenCalledTimes(2); |
802 | 809 | expect(reloadTaskRegistryFromStore).toHaveBeenCalledTimes(2); |
803 | 810 | expect(acquireGatewayLock).toHaveBeenCalledTimes(3); |
|