hotfix: fix acceptance test (#2296)

airbytehq · Mar 3, 2021 · 75a5923 · 75a5923
1 parent a39eb4f
commit 75a5923
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/airbyte-tests/src/acceptanceTests/java/io/airbyte/test/acceptance/AcceptanceTests.java b/airbyte-tests/src/acceptanceTests/java/io/airbyte/test/acceptance/AcceptanceTests.java
@@ -378,7 +378,8 @@ public void testIncrementalSync() throws Exception {
     assertDestinationContains(expectedRecords, STREAM_NAME);
 
     // reset back to no data.
-    apiClient.getConnectionApi().resetConnection(new ConnectionIdRequestBody().connectionId(connectionId));
+    final JobInfoRead jobInfoRead = apiClient.getConnectionApi().resetConnection(new ConnectionIdRequestBody().connectionId(connectionId));
+    waitForSuccessfulJob(apiClient.getJobsApi(), jobInfoRead.getJob());
     assertDestinationContains(Collections.emptyList(), STREAM_NAME);
 
     // sync one more time. verify it is the equivalent of a full refresh.