@@ -44,6 +44,7 @@ import algoliasearch.ingestion.RunSortKeys._
44
44
import algoliasearch .ingestion .RunSourcePayload
45
45
import algoliasearch .ingestion .RunSourceResponse
46
46
import algoliasearch .ingestion .RunStatus ._
47
+ import algoliasearch .ingestion .RunTaskPayload
47
48
import algoliasearch .ingestion .RunType ._
48
49
import algoliasearch .ingestion .Source
49
50
import algoliasearch .ingestion .SourceCreate
@@ -1338,16 +1339,20 @@ class IngestionClient(
1338
1339
*
1339
1340
* @param taskID
1340
1341
* Unique identifier of a task.
1342
+ * @param runTaskPayload
1341
1343
*/
1342
- def runTask (taskID : String , requestOptions : Option [RequestOptions ] = None )(implicit
1343
- ec : ExecutionContext
1344
- ): Future [RunResponse ] = Future {
1344
+ def runTask (
1345
+ taskID : String ,
1346
+ runTaskPayload : Option [RunTaskPayload ] = None ,
1347
+ requestOptions : Option [RequestOptions ] = None
1348
+ )(implicit ec : ExecutionContext ): Future [RunResponse ] = Future {
1345
1349
requireNotNull(taskID, " Parameter `taskID` is required when calling `runTask`." )
1346
1350
1347
1351
val request = HttpRequest
1348
1352
.builder()
1349
1353
.withMethod(" POST" )
1350
1354
.withPath(s " /2/tasks/ ${escape(taskID)}/run " )
1355
+ .withBody(runTaskPayload)
1351
1356
.build()
1352
1357
execute[RunResponse ](request, requestOptions)
1353
1358
}
@@ -1364,16 +1369,20 @@ class IngestionClient(
1364
1369
*
1365
1370
* @param taskID
1366
1371
* Unique identifier of a task.
1372
+ * @param runTaskPayload
1367
1373
*/
1368
- def runTaskV1 (taskID : String , requestOptions : Option [RequestOptions ] = None )(implicit
1369
- ec : ExecutionContext
1370
- ): Future [RunResponse ] = Future {
1374
+ def runTaskV1 (
1375
+ taskID : String ,
1376
+ runTaskPayload : Option [RunTaskPayload ] = None ,
1377
+ requestOptions : Option [RequestOptions ] = None
1378
+ )(implicit ec : ExecutionContext ): Future [RunResponse ] = Future {
1371
1379
requireNotNull(taskID, " Parameter `taskID` is required when calling `runTaskV1`." )
1372
1380
1373
1381
val request = HttpRequest
1374
1382
.builder()
1375
1383
.withMethod(" POST" )
1376
1384
.withPath(s " /1/tasks/ ${escape(taskID)}/run " )
1385
+ .withBody(runTaskPayload)
1377
1386
.build()
1378
1387
execute[RunResponse ](request, requestOptions)
1379
1388
}
0 commit comments