test("create rule with non existent source key fails", async () => {
    const aggregation = new Aggregation(AggregationType.COUNT, 50000);
    await expect(rtsClient.createRule("rule3", "rule2", aggregation)).rejects.toThrow();
});