@@ -135,22 +135,34 @@ public function testCancelTasksWithFilter(): void
135
135
self ::assertSame ('taskCancelation ' , $ promise ['type ' ]);
136
136
$ response = $ this ->client ->waitForTask ($ promise ['taskUid ' ]);
137
137
138
- self ::assertSame ('? ' . $ query , $ response ['details ' ]['originalFilter ' ]);
138
+ self ::assertSame ('? ' . $ query , $ response ['details ' ]['originalFilter ' ]);
139
139
self ::assertSame ('taskCancelation ' , $ response ['type ' ]);
140
140
self ::assertSame ('succeeded ' , $ response ['status ' ]);
141
141
}
142
142
143
143
public function testGetAllTasksInReverseOrder (): void
144
144
{
145
- $ date = new \DateTime ();
145
+ $ startDate = new \DateTime (' now ' );
146
146
147
- $ this ->seedIndex ();
148
- $ this ->seedIndex ();
147
+ // $response = $this->client->createIndex($this->indexName . '-tmp-for-reverse-tasks');
148
+ // $this->client->waitForTask($response['taskUid']);
149
+ // $response = $this->client->createIndex($this->indexName . '-tmp-for-reverse-tasks-2');
150
+ // $this->client->waitForTask($response['taskUid']);
151
+
152
+ // sleep(1);
153
+
154
+ // $endDate = new \DateTime('now');
149
155
150
- $ tasks = $ this ->client ->getTasks ((new TasksQuery ())->setAfterEnqueuedAt ($ date )->setLimit (2 ));
151
- $ reversedTasks = $ this ->client ->getTasks ((new TasksQuery ())->setAfterEnqueuedAt ($ date )->setReverse (true )->setLimit (2 ));
156
+ $ tasks = $ this ->client ->getTasks ((new TasksQuery ())
157
+ ->setAfterEnqueuedAt ($ startDate )
158
+ );
159
+ $ reversedTasks = $ this ->client ->getTasks ((new TasksQuery ())
160
+ ->setAfterEnqueuedAt ($ startDate )
161
+ ->setReverse (true )
162
+ );
152
163
153
- self ::assertSame ($ reversedTasks ->getResults (), array_reverse ($ tasks ->getResults ()));
164
+ self ::assertSameSize ($ tasks ->getResults (), $ reversedTasks ->getResults ());
165
+ self ::assertSame ($ tasks ->getResults (), array_reverse ($ reversedTasks ->getResults ()));
154
166
}
155
167
156
168
public function testExceptionIfNoTaskIdWhenGetting (): void
0 commit comments