diff --git a/src/gateway/server-http.request-trace.test.ts b/src/gateway/server-http.request-trace.test.ts index 0cdba3df5e4..b1a7023aefa 100644 --- a/src/gateway/server-http.request-trace.test.ts +++ b/src/gateway/server-http.request-trace.test.ts @@ -93,10 +93,8 @@ describe("gateway HTTP request trace scope", () => { .split("\n") .map((line) => JSON.parse(line) as Record) .find((record) => record.message === "handled request trace"); - expect(traceRecord).toMatchObject({ - traceId: activeTraceInHandler?.traceId, - spanId: activeTraceInHandler?.spanId, - }); + expect(traceRecord?.traceId).toBe(activeTraceInHandler?.traceId); + expect(traceRecord?.spanId).toBe(activeTraceInHandler?.spanId); } finally { fs.rmSync(dir, { recursive: true, force: true }); } diff --git a/src/gateway/server-runtime-services.test.ts b/src/gateway/server-runtime-services.test.ts index 9e5a6d8e7e9..48844d8f370 100644 --- a/src/gateway/server-runtime-services.test.ts +++ b/src/gateway/server-runtime-services.test.ts @@ -185,18 +185,16 @@ describe("server-runtime-services", () => { expect(services.heartbeatRunner).toBe(hoisted.heartbeatRunner); await vi.advanceTimersByTimeAsync(1_250); await vi.dynamicImportSettled(); - expect(hoisted.recoverPendingDeliveries).toHaveBeenCalledWith( - expect.objectContaining({ - deliver: hoisted.deliverOutboundPayloads, - cfg: {}, - }), - ); - expect(hoisted.recoverPendingRestartContinuationDeliveries).toHaveBeenCalledWith( - expect.objectContaining({ - deps: {}, - maxEnqueuedAt: 123, - }), - ); + expect(hoisted.recoverPendingDeliveries).toHaveBeenCalledWith({ + deliver: hoisted.deliverOutboundPayloads, + cfg: {}, + log: expect.any(Object), + }); + expect(hoisted.recoverPendingRestartContinuationDeliveries).toHaveBeenCalledWith({ + deps: {}, + maxEnqueuedAt: 123, + log: expect.any(Object), + }); }); it("can defer cron startup while activating other scheduled services", async () => {