@@ -925,7 +925,7 @@ public class IngestionClient(
925
925
* @param watch When provided, the push operation will be synchronous and the API will wait for the ingestion to be finished before responding.
926
926
* @param requestOptions additional request configuration.
927
927
*/
928
- public suspend fun pushTask (taskID : String , pushTaskPayload : PushTaskPayload , watch : Boolean? = null, requestOptions : RequestOptions ? = null): RunResponse {
928
+ public suspend fun pushTask (taskID : String , pushTaskPayload : PushTaskPayload , watch : Boolean? = null, requestOptions : RequestOptions ? = null): WatchResponse {
929
929
require(taskID.isNotBlank()) { " Parameter `taskID` is required when calling `pushTask`." }
930
930
val requestConfig = RequestConfig (
931
931
method = RequestMethod .POST ,
@@ -1151,7 +1151,7 @@ public class IngestionClient(
1151
1151
* @param sourceID Unique identifier of a source.
1152
1152
* @param requestOptions additional request configuration.
1153
1153
*/
1154
- public suspend fun triggerDockerSourceDiscover (sourceID : String , requestOptions : RequestOptions ? = null): SourceWatchResponse {
1154
+ public suspend fun triggerDockerSourceDiscover (sourceID : String , requestOptions : RequestOptions ? = null): WatchResponse {
1155
1155
require(sourceID.isNotBlank()) { " Parameter `sourceID` is required when calling `triggerDockerSourceDiscover`." }
1156
1156
val requestConfig = RequestConfig (
1157
1157
method = RequestMethod .POST ,
@@ -1348,7 +1348,7 @@ public class IngestionClient(
1348
1348
* @param sourceCreate
1349
1349
* @param requestOptions additional request configuration.
1350
1350
*/
1351
- public suspend fun validateSource (sourceCreate : SourceCreate ? = null, requestOptions : RequestOptions ? = null): SourceWatchResponse {
1351
+ public suspend fun validateSource (sourceCreate : SourceCreate ? = null, requestOptions : RequestOptions ? = null): WatchResponse {
1352
1352
val requestConfig = RequestConfig (
1353
1353
method = RequestMethod .POST ,
1354
1354
path = listOf (" 1" , " sources" , " validate" ),
@@ -1371,7 +1371,7 @@ public class IngestionClient(
1371
1371
* @param sourceUpdate
1372
1372
* @param requestOptions additional request configuration.
1373
1373
*/
1374
- public suspend fun validateSourceBeforeUpdate (sourceID : String , sourceUpdate : SourceUpdate , requestOptions : RequestOptions ? = null): SourceWatchResponse {
1374
+ public suspend fun validateSourceBeforeUpdate (sourceID : String , sourceUpdate : SourceUpdate , requestOptions : RequestOptions ? = null): WatchResponse {
1375
1375
require(sourceID.isNotBlank()) { " Parameter `sourceID` is required when calling `validateSourceBeforeUpdate`." }
1376
1376
val requestConfig = RequestConfig (
1377
1377
method = RequestMethod .POST ,
0 commit comments