[AT] Increase polling delay.

Author: Corneil du Plessis

performance-tests/stream-perf-tests-initializer/src/main/java/org/springframework/cloud/dataflow/perf/test/stream/StreamPerformanceTestInitializer.java

@@ -107,7 +107,8 @@ public CommandLineRunner commandLineRunner(DataFlowOperations dataFlowOperations
                             if (i < streamDefinitionList.size()) {
                                 Stream stream = streamDefinitionList.get(i).deploy(testDeploymentProperties(runtimeApps));
                                 deployedStreams.add(stream);
-                                Awaitility.await().until(() -> stream.getStatus().equals("deployed"));
+                                Awaitility.await()
+                                    .until(() -> stream.getStatus().equals("deployed"));
                             }
                         }
 

src/test/java/org/springframework/cloud/dataflow/acceptance/test/BatchRemotePartitioningAT.java

@@ -109,7 +109,8 @@ public void runBatchRemotePartitionJobCloudFoundry() {
 
             LaunchResponseResource launch = task.launch(Collections.EMPTY_MAP, Arrays.asList("--platform=cloudfoundry"));
 
-            Awaitility.await().until(() -> task.executionStatus(launch.getExecutionId(), launch.getSchemaTarget()) == TaskExecutionStatus.COMPLETE);
+            Awaitility.await()
+                .until(() -> task.executionStatus(launch.getExecutionId(), launch.getSchemaTarget()) == TaskExecutionStatus.COMPLETE);
             assertThat(task.executions().size()).isEqualTo(1);
             Optional<TaskExecutionResource> taskExecution = task.execution(launch.getExecutionId(), launch.getSchemaTarget());
             assertThat(taskExecution).isPresent();