raise timeout on flaky test (#10868)

Author: lmossman

airbyte-workers/src/test/java/io/airbyte/workers/temporal/scheduling/ConnectionManagerWorkflowTest.java

@@ -503,7 +503,7 @@ public void cancelRunning() throws InterruptedException {
       final Queue<ChangedStateEvent> eventQueue = testStateListener.events(testId);
       final List<ChangedStateEvent> events = new ArrayList<>(eventQueue);
 
-      for (ChangedStateEvent event : events) {
+      for (final ChangedStateEvent event : events) {
         if (event.isValue()) {
           log.info("event = " + event);
         }
@@ -549,7 +549,7 @@ public void resetStart() throws InterruptedException {
     }
 
     @RepeatedTest(10)
-    @Timeout(value = 10,
+    @Timeout(value = 30,
              unit = TimeUnit.SECONDS)
     @DisplayName("Test that resetting a running workflow cancels the running workflow")
     public void resetCancelRunningWorkflow() throws InterruptedException {
@@ -578,7 +578,7 @@ public void resetCancelRunningWorkflow() throws InterruptedException {
       final Queue<ChangedStateEvent> eventQueue = testStateListener.events(testId);
       final List<ChangedStateEvent> events = new ArrayList<>(eventQueue);
 
-      for (ChangedStateEvent event : events) {
+      for (final ChangedStateEvent event : events) {
         if (event.isValue()) {
           log.info("event = " + event);
         }
@@ -667,7 +667,7 @@ public void updatedSignalReceivedWhileRunning() throws InterruptedException {
       final Queue<ChangedStateEvent> eventQueue = testStateListener.events(testId);
       final List<ChangedStateEvent> events = new ArrayList<>(eventQueue);
 
-      for (ChangedStateEvent event : events) {
+      for (final ChangedStateEvent event : events) {
         if (event.isValue()) {
           log.info("event = " + event);
         }
@@ -883,7 +883,7 @@ public static Stream<Arguments> getSetupFailingFailingActivityBeforeRun() {
 
     @ParameterizedTest
     @MethodSource("getSetupFailingFailingActivityBeforeRun")
-    void testGetStuckBeforeRun(Thread mockSetup) throws InterruptedException {
+    void testGetStuckBeforeRun(final Thread mockSetup) throws InterruptedException {
       mockSetup.run();
       Mockito.when(mConfigFetchActivity.getTimeToWait(Mockito.any())).thenReturn(new ScheduleRetrieverOutput(
           Duration.ZERO));
@@ -973,7 +973,7 @@ public static Stream<Arguments> getSetupFailingFailingActivityAfterRun() {
 
     @ParameterizedTest
     @MethodSource("getSetupFailingFailingActivityAfterRun")
-    void testGetStuckAfterRun(Consumer<ConnectionManagerWorkflow> signalSender, Thread mockSetup) throws InterruptedException {
+    void testGetStuckAfterRun(final Consumer<ConnectionManagerWorkflow> signalSender, final Thread mockSetup) throws InterruptedException {
       mockSetup.run();
 
       final UUID testId = UUID.randomUUID();
@@ -1055,7 +1055,7 @@ private static void startWorkflowAndWaitUntilReady(final ConnectionManagerWorkfl
     while (!isReady) {
       try {
         isReady = workflow.getState() != null;
-      } catch (Exception e) {
+      } catch (final Exception e) {
         log.info("retrying...");
         Thread.sleep(100);
       }