From 3bfed90817136ec567a506160e9564fe2bf4983d Mon Sep 17 00:00:00 2001 From: Joe Bell Date: Tue, 2 Jan 2024 16:32:43 -0800 Subject: [PATCH] formatting --- .../typing_deduping/TypeAndDedupeOperationValveTest.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/airbyte-cdk/java/airbyte-cdk/typing-deduping/src/test/java/io/airbyte/integrations/base/destination/typing_deduping/TypeAndDedupeOperationValveTest.java b/airbyte-cdk/java/airbyte-cdk/typing-deduping/src/test/java/io/airbyte/integrations/base/destination/typing_deduping/TypeAndDedupeOperationValveTest.java index ff1acf80fec1..3ada28f544d4 100644 --- a/airbyte-cdk/java/airbyte-cdk/typing-deduping/src/test/java/io/airbyte/integrations/base/destination/typing_deduping/TypeAndDedupeOperationValveTest.java +++ b/airbyte-cdk/java/airbyte-cdk/typing-deduping/src/test/java/io/airbyte/integrations/base/destination/typing_deduping/TypeAndDedupeOperationValveTest.java @@ -90,7 +90,9 @@ public void testUpdateTimeAndIncreaseInterval(final boolean enableIncrementalTyp initializeDestinationConfigOption(enableIncrementalTypingAndDeduping); final var valve = new TypeAndDedupeOperationValve(minuteUpdates); valve.addStream(STREAM_A); - IntStream.range(0, 1).forEach(__ -> Assertions.assertEquals(valve.readyToTypeAndDedupe(STREAM_A), enableIncrementalTypingAndDeduping)); // start ready to T&D + IntStream.range(0, 1).forEach(__ -> Assertions.assertEquals(valve.readyToTypeAndDedupe(STREAM_A), enableIncrementalTypingAndDeduping)); // start + // ready + // to T&D Assertions.assertEquals(valve.readyToTypeAndDedupe(STREAM_A), enableIncrementalTypingAndDeduping); valve.updateTimeAndIncreaseInterval(STREAM_A); IntStream.range(0, 360).forEach(__ -> Assertions.assertFalse(valve.readyToTypeAndDedupe(STREAM_A)));