@@ -925,7 +925,7 @@ public class IngestionClient(
925925 * @param watch When provided, the push operation will be synchronous and the API will wait for the ingestion to be finished before responding.
926926 * @param requestOptions additional request configuration.
927927 */
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 {
929929 require(taskID.isNotBlank()) { " Parameter `taskID` is required when calling `pushTask`." }
930930 val requestConfig = RequestConfig (
931931 method = RequestMethod .POST ,
@@ -1151,7 +1151,7 @@ public class IngestionClient(
11511151 * @param sourceID Unique identifier of a source.
11521152 * @param requestOptions additional request configuration.
11531153 */
1154- public suspend fun triggerDockerSourceDiscover (sourceID : String , requestOptions : RequestOptions ? = null): SourceWatchResponse {
1154+ public suspend fun triggerDockerSourceDiscover (sourceID : String , requestOptions : RequestOptions ? = null): WatchResponse {
11551155 require(sourceID.isNotBlank()) { " Parameter `sourceID` is required when calling `triggerDockerSourceDiscover`." }
11561156 val requestConfig = RequestConfig (
11571157 method = RequestMethod .POST ,
@@ -1348,7 +1348,7 @@ public class IngestionClient(
13481348 * @param sourceCreate
13491349 * @param requestOptions additional request configuration.
13501350 */
1351- public suspend fun validateSource (sourceCreate : SourceCreate ? = null, requestOptions : RequestOptions ? = null): SourceWatchResponse {
1351+ public suspend fun validateSource (sourceCreate : SourceCreate ? = null, requestOptions : RequestOptions ? = null): WatchResponse {
13521352 val requestConfig = RequestConfig (
13531353 method = RequestMethod .POST ,
13541354 path = listOf (" 1" , " sources" , " validate" ),
@@ -1371,7 +1371,7 @@ public class IngestionClient(
13711371 * @param sourceUpdate
13721372 * @param requestOptions additional request configuration.
13731373 */
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 {
13751375 require(sourceID.isNotBlank()) { " Parameter `sourceID` is required when calling `validateSourceBeforeUpdate`." }
13761376 val requestConfig = RequestConfig (
13771377 method = RequestMethod .POST ,
0 commit comments