fix: extend timeout (GoogleCloudPlatform#5697)

averikitsch · web-flow · commit 5f0ff7063804 · 2021-07-26T10:19:06.000-07:00
* fix: extend timeout

* synchronize

* lint
diff --git a/unittests/src/test/java/com/google/appengine/samples/DeferredTaskTest.java b/unittests/src/test/java/com/google/appengine/samples/DeferredTaskTest.java
@@ -36,11 +36,12 @@ public class DeferredTaskTest extends BaseTestConfiguration {
   private static final LocalTaskQueueTestConfig.TaskCountDownLatch latch =
       new LocalTaskQueueTestConfig.TaskCountDownLatch(1);
 
-  private final LocalServiceTestHelper helper =
-      new LocalServiceTestHelper(new LocalTaskQueueTestConfig()
-          .setDisableAutoTaskExecution(false) // Enable auto task execution
-          .setCallbackClass(LocalTaskQueueTestConfig.DeferredTaskCallback.class)
-          .setTaskExecutionLatch(latch));
+  private static final LocalServiceTestHelper helper =
+      new LocalServiceTestHelper(
+          new LocalTaskQueueTestConfig()
+              .setDisableAutoTaskExecution(false) // Enable auto task execution
+              .setCallbackClass(LocalTaskQueueTestConfig.DeferredTaskCallback.class)
+              .setTaskExecutionLatch(latch));
 
   private static synchronized boolean requestAwait() throws InterruptedException {
     return latch.await(5, TimeUnit.SECONDS);
@@ -50,6 +51,14 @@ private static synchronized void requestReset() {
     latch.reset();
   }
 
+  private static synchronized void helperSetUp() {
+    helper.setUp();
+  }
+
+  private static synchronized void helperTearDown() {
+    helper.tearDown();
+  }
+
   private static class MyTask implements DeferredTask {
     private static volatile boolean taskRan = false;
 
@@ -61,20 +70,19 @@ public void run() {
 
   @Before
   public void setUp() {
-    helper.setUp();
+    helperSetUp();
   }
 
   @After
   public void tearDown() {
     MyTask.taskRan = false;
     requestReset();
-    helper.tearDown();
+    helperTearDown();
   }
 
   @Test
   public void testTaskGetsRun() throws InterruptedException {
-    QueueFactory.getDefaultQueue().add(
-        TaskOptions.Builder.withPayload(new MyTask()));
+    QueueFactory.getDefaultQueue().add(TaskOptions.Builder.withPayload(new MyTask()));
     assertTrue(requestAwait());
     assertTrue(MyTask.taskRan);
   }
