expect(ctx.shouldAckAfter("receive_record")).toBe(false);

expect(ctx.shouldAckAfter("durable_send")).toBe(true);

const beforeAck = Date.now();

await ctx.ack();

await ctx.ack();

expect(onAck).toHaveBeenCalledTimes(1);

expect(ctx.ackState).toBe("acked");

expect(ctx.ackedAt).toEqual(expect.any(Number));

expect(ctx.ackedAt).toBeGreaterThanOrEqual(beforeAck);

await ctx.nack(new Error("offset failed"));

expect(onNack).toHaveBeenCalledWith(expect.any(Error));

message: "watch dbus",

toolsAllow: ["exec"],

});

expect(job.state.nextRunAtMs).toEqual(expect.any(Number));

expect(job.state.nextRunAtMs).toBeGreaterThan(STORE_TEST_NOW);

expect(assertSupportedJobSpec(job)).toBeUndefined();

});

count: 2,

},

});

expect(event?.timestamp).toEqual(expect.any(String));

expect(event?.pid).toEqual(expect.any(Number));

expect(event?.timestamp).toMatch(/^\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}\.\d{3}Z$/u);

expect(event?.pid).toBe(process.pid);

expect((event?.attributes as Record<string, unknown>).ignored).toBeUndefined();

});

attributes: { pluginCount: 3 },

});

expect(events[1]?.spanId).toBe(events[0]?.spanId);

expect(events[1]?.durationMs).toEqual(expect.any(Number));

expect(events[1]?.durationMs).toBeGreaterThanOrEqual(0);

});

it("records span error events and rethrows failures", async () => {