@@ -138,6 +138,22 @@ public void testClientGetTaskErrorWhenAddingDocuments() throws Exception {
138138 /** Test Get Tasks with limit and from */
139139 @ Test
140140 public void testClientGetTasksLimitAndFrom () throws Exception {
141+ // Create several indexes to make sure we have enough tasks
142+ String indexUid1 = "GetClientTasksLimitFrom1" ;
143+ String indexUid2 = "GetClientTasksLimitFrom2" ;
144+ String indexUid3 = "GetClientTasksLimitFrom3" ;
145+ String indexUid4 = "GetClientTasksLimitFrom4" ;
146+
147+ // Create indexes to generate tasks
148+ TaskInfo response1 = client .createIndex (indexUid1 );
149+ client .waitForTask (response1 .getTaskUid ());
150+ TaskInfo response2 = client .createIndex (indexUid2 );
151+ client .waitForTask (response2 .getTaskUid ());
152+ TaskInfo response3 = client .createIndex (indexUid3 );
153+ client .waitForTask (response3 .getTaskUid ());
154+ TaskInfo response4 = client .createIndex (indexUid4 );
155+ client .waitForTask (response4 .getTaskUid ());
156+
141157 int limit = 2 ;
142158 int from = 2 ;
143159 TasksQuery query = new TasksQuery ().setLimit (limit ).setFrom (from );
@@ -147,7 +163,7 @@ public void testClientGetTasksLimitAndFrom() throws Exception {
147163 assertThat (result .getFrom (), is (equalTo (from )));
148164 assertThat (result .getFrom (), is (notNullValue ()));
149165 assertThat (result .getNext (), is (notNullValue ()));
150- assertThat (result .getResults ().length , is (notNullValue ( )));
166+ assertThat (result .getResults ().length , is (equalTo ( limit )));
151167 }
152168
153169 /** Test Get Tasks with uid as filter */
0 commit comments