@@ -1281,8 +1281,8 @@ public interface IIngestionClient
12811281 /// <exception cref="ArgumentException">Thrown when arguments are not correct</exception>
12821282 /// <exception cref="Algolia.Search.Exceptions.AlgoliaApiException">Thrown when the API call was rejected by Algolia</exception>
12831283 /// <exception cref="Algolia.Search.Exceptions.AlgoliaUnreachableHostException">Thrown when the client failed to call the endpoint</exception>
1284- /// <returns>Task of RunResponse </returns>
1285- Task < RunResponse > PushTaskAsync ( string taskID , PushTaskPayload pushTaskPayload , bool ? watch = default , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
1284+ /// <returns>Task of WatchResponse </returns>
1285+ Task < WatchResponse > PushTaskAsync ( string taskID , PushTaskPayload pushTaskPayload , bool ? watch = default , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
12861286
12871287 /// <summary>
12881288 /// Push a `batch` request payload through the Pipeline. You can check the status of task pushes with the observability endpoints. (Synchronous version)
@@ -1300,8 +1300,8 @@ public interface IIngestionClient
13001300 /// <exception cref="ArgumentException">Thrown when arguments are not correct</exception>
13011301 /// <exception cref="Algolia.Search.Exceptions.AlgoliaApiException">Thrown when the API call was rejected by Algolia</exception>
13021302 /// <exception cref="Algolia.Search.Exceptions.AlgoliaUnreachableHostException">Thrown when the client failed to call the endpoint</exception>
1303- /// <returns>RunResponse </returns>
1304- RunResponse PushTask ( string taskID , PushTaskPayload pushTaskPayload , bool ? watch = default , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
1303+ /// <returns>WatchResponse </returns>
1304+ WatchResponse PushTask ( string taskID , PushTaskPayload pushTaskPayload , bool ? watch = default , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
13051305
13061306 /// <summary>
13071307 /// Runs all tasks linked to a source, only available for Shopify sources. It will create 1 run per task.
@@ -1625,8 +1625,8 @@ public interface IIngestionClient
16251625 /// <exception cref="ArgumentException">Thrown when arguments are not correct</exception>
16261626 /// <exception cref="Algolia.Search.Exceptions.AlgoliaApiException">Thrown when the API call was rejected by Algolia</exception>
16271627 /// <exception cref="Algolia.Search.Exceptions.AlgoliaUnreachableHostException">Thrown when the client failed to call the endpoint</exception>
1628- /// <returns>Task of SourceWatchResponse </returns>
1629- Task < SourceWatchResponse > TriggerDockerSourceDiscoverAsync ( string sourceID , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
1628+ /// <returns>Task of WatchResponse </returns>
1629+ Task < WatchResponse > TriggerDockerSourceDiscoverAsync ( string sourceID , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
16301630
16311631 /// <summary>
16321632 /// Triggers a stream-listing request for a source. Triggering stream-listing requests only works with sources with `type: docker` and `imageType: singer`. (Synchronous version)
@@ -1642,8 +1642,8 @@ public interface IIngestionClient
16421642 /// <exception cref="ArgumentException">Thrown when arguments are not correct</exception>
16431643 /// <exception cref="Algolia.Search.Exceptions.AlgoliaApiException">Thrown when the API call was rejected by Algolia</exception>
16441644 /// <exception cref="Algolia.Search.Exceptions.AlgoliaUnreachableHostException">Thrown when the client failed to call the endpoint</exception>
1645- /// <returns>SourceWatchResponse </returns>
1646- SourceWatchResponse TriggerDockerSourceDiscover ( string sourceID , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
1645+ /// <returns>WatchResponse </returns>
1646+ WatchResponse TriggerDockerSourceDiscover ( string sourceID , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
16471647
16481648 /// <summary>
16491649 /// Try a transformation before creating it.
@@ -1915,8 +1915,8 @@ public interface IIngestionClient
19151915 /// <exception cref="ArgumentException">Thrown when arguments are not correct</exception>
19161916 /// <exception cref="Algolia.Search.Exceptions.AlgoliaApiException">Thrown when the API call was rejected by Algolia</exception>
19171917 /// <exception cref="Algolia.Search.Exceptions.AlgoliaUnreachableHostException">Thrown when the client failed to call the endpoint</exception>
1918- /// <returns>Task of SourceWatchResponse </returns>
1919- Task < SourceWatchResponse > ValidateSourceAsync ( SourceCreate sourceCreate = default , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
1918+ /// <returns>Task of WatchResponse </returns>
1919+ Task < WatchResponse > ValidateSourceAsync ( SourceCreate sourceCreate = default , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
19201920
19211921 /// <summary>
19221922 /// Validates a source payload to ensure it can be created and that the data source can be reached by Algolia. (Synchronous version)
@@ -1932,8 +1932,8 @@ public interface IIngestionClient
19321932 /// <exception cref="ArgumentException">Thrown when arguments are not correct</exception>
19331933 /// <exception cref="Algolia.Search.Exceptions.AlgoliaApiException">Thrown when the API call was rejected by Algolia</exception>
19341934 /// <exception cref="Algolia.Search.Exceptions.AlgoliaUnreachableHostException">Thrown when the client failed to call the endpoint</exception>
1935- /// <returns>SourceWatchResponse </returns>
1936- SourceWatchResponse ValidateSource ( SourceCreate sourceCreate = default , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
1935+ /// <returns>WatchResponse </returns>
1936+ WatchResponse ValidateSource ( SourceCreate sourceCreate = default , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
19371937
19381938 /// <summary>
19391939 /// Validates an update of a source payload to ensure it can be created and that the data source can be reached by Algolia.
@@ -1950,8 +1950,8 @@ public interface IIngestionClient
19501950 /// <exception cref="ArgumentException">Thrown when arguments are not correct</exception>
19511951 /// <exception cref="Algolia.Search.Exceptions.AlgoliaApiException">Thrown when the API call was rejected by Algolia</exception>
19521952 /// <exception cref="Algolia.Search.Exceptions.AlgoliaUnreachableHostException">Thrown when the client failed to call the endpoint</exception>
1953- /// <returns>Task of SourceWatchResponse </returns>
1954- Task < SourceWatchResponse > ValidateSourceBeforeUpdateAsync ( string sourceID , SourceUpdate sourceUpdate , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
1953+ /// <returns>Task of WatchResponse </returns>
1954+ Task < WatchResponse > ValidateSourceBeforeUpdateAsync ( string sourceID , SourceUpdate sourceUpdate , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
19551955
19561956 /// <summary>
19571957 /// Validates an update of a source payload to ensure it can be created and that the data source can be reached by Algolia. (Synchronous version)
@@ -1968,8 +1968,8 @@ public interface IIngestionClient
19681968 /// <exception cref="ArgumentException">Thrown when arguments are not correct</exception>
19691969 /// <exception cref="Algolia.Search.Exceptions.AlgoliaApiException">Thrown when the API call was rejected by Algolia</exception>
19701970 /// <exception cref="Algolia.Search.Exceptions.AlgoliaUnreachableHostException">Thrown when the client failed to call the endpoint</exception>
1971- /// <returns>SourceWatchResponse </returns>
1972- SourceWatchResponse ValidateSourceBeforeUpdate ( string sourceID , SourceUpdate sourceUpdate , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
1971+ /// <returns>WatchResponse </returns>
1972+ WatchResponse ValidateSourceBeforeUpdate ( string sourceID , SourceUpdate sourceUpdate , RequestOptions options = null , CancellationToken cancellationToken = default ) ;
19731973
19741974}
19751975
@@ -2804,7 +2804,7 @@ public ListTransformationsResponse ListTransformations(int? itemsPerPage = defau
28042804
28052805
28062806 /// <inheritdoc />
2807- public async Task < RunResponse > PushTaskAsync ( string taskID , PushTaskPayload pushTaskPayload , bool ? watch = default , RequestOptions options = null , CancellationToken cancellationToken = default )
2807+ public async Task < WatchResponse > PushTaskAsync ( string taskID , PushTaskPayload pushTaskPayload , bool ? watch = default , RequestOptions options = null , CancellationToken cancellationToken = default )
28082808 {
28092809
28102810 if ( taskID == null )
@@ -2820,12 +2820,12 @@ public async Task<RunResponse> PushTaskAsync(string taskID, PushTaskPayload push
28202820
28212821 requestOptions . AddQueryParameter ( "watch" , watch ) ;
28222822 requestOptions . Data = pushTaskPayload ;
2823- return await _transport . ExecuteRequestAsync < RunResponse > ( new HttpMethod ( "POST" ) , "/2/tasks/{taskID}/push" , requestOptions , cancellationToken ) . ConfigureAwait ( false ) ;
2823+ return await _transport . ExecuteRequestAsync < WatchResponse > ( new HttpMethod ( "POST" ) , "/2/tasks/{taskID}/push" , requestOptions , cancellationToken ) . ConfigureAwait ( false ) ;
28242824 }
28252825
28262826
28272827 /// <inheritdoc />
2828- public RunResponse PushTask ( string taskID , PushTaskPayload pushTaskPayload , bool ? watch = default , RequestOptions options = null , CancellationToken cancellationToken = default ) =>
2828+ public WatchResponse PushTask ( string taskID , PushTaskPayload pushTaskPayload , bool ? watch = default , RequestOptions options = null , CancellationToken cancellationToken = default ) =>
28292829 AsyncHelper . RunSync ( ( ) => PushTaskAsync ( taskID , pushTaskPayload , watch , options , cancellationToken ) ) ;
28302830
28312831
@@ -3011,7 +3011,7 @@ public List<Transformation> SearchTransformations(TransformationSearch transform
30113011
30123012
30133013 /// <inheritdoc />
3014- public async Task < SourceWatchResponse > TriggerDockerSourceDiscoverAsync ( string sourceID , RequestOptions options = null , CancellationToken cancellationToken = default )
3014+ public async Task < WatchResponse > TriggerDockerSourceDiscoverAsync ( string sourceID , RequestOptions options = null , CancellationToken cancellationToken = default )
30153015 {
30163016
30173017 if ( sourceID == null )
@@ -3021,12 +3021,12 @@ public async Task<SourceWatchResponse> TriggerDockerSourceDiscoverAsync(string s
30213021
30223022 requestOptions . PathParameters . Add ( "sourceID" , QueryStringHelper . ParameterToString ( sourceID ) ) ;
30233023
3024- return await _transport . ExecuteRequestAsync < SourceWatchResponse > ( new HttpMethod ( "POST" ) , "/1/sources/{sourceID}/discover" , requestOptions , cancellationToken ) . ConfigureAwait ( false ) ;
3024+ return await _transport . ExecuteRequestAsync < WatchResponse > ( new HttpMethod ( "POST" ) , "/1/sources/{sourceID}/discover" , requestOptions , cancellationToken ) . ConfigureAwait ( false ) ;
30253025 }
30263026
30273027
30283028 /// <inheritdoc />
3029- public SourceWatchResponse TriggerDockerSourceDiscover ( string sourceID , RequestOptions options = null , CancellationToken cancellationToken = default ) =>
3029+ public WatchResponse TriggerDockerSourceDiscover ( string sourceID , RequestOptions options = null , CancellationToken cancellationToken = default ) =>
30303030 AsyncHelper . RunSync ( ( ) => TriggerDockerSourceDiscoverAsync ( sourceID , options , cancellationToken ) ) ;
30313031
30323032
@@ -3226,23 +3226,23 @@ public TransformationUpdateResponse UpdateTransformation(string transformationID
32263226
32273227
32283228 /// <inheritdoc />
3229- public async Task < SourceWatchResponse > ValidateSourceAsync ( SourceCreate sourceCreate = default , RequestOptions options = null , CancellationToken cancellationToken = default )
3229+ public async Task < WatchResponse > ValidateSourceAsync ( SourceCreate sourceCreate = default , RequestOptions options = null , CancellationToken cancellationToken = default )
32303230 {
32313231 var requestOptions = new InternalRequestOptions ( options ) ;
32323232
32333233
32343234 requestOptions . Data = sourceCreate ;
3235- return await _transport . ExecuteRequestAsync < SourceWatchResponse > ( new HttpMethod ( "POST" ) , "/1/sources/validate" , requestOptions , cancellationToken ) . ConfigureAwait ( false ) ;
3235+ return await _transport . ExecuteRequestAsync < WatchResponse > ( new HttpMethod ( "POST" ) , "/1/sources/validate" , requestOptions , cancellationToken ) . ConfigureAwait ( false ) ;
32363236 }
32373237
32383238
32393239 /// <inheritdoc />
3240- public SourceWatchResponse ValidateSource ( SourceCreate sourceCreate = default , RequestOptions options = null , CancellationToken cancellationToken = default ) =>
3240+ public WatchResponse ValidateSource ( SourceCreate sourceCreate = default , RequestOptions options = null , CancellationToken cancellationToken = default ) =>
32413241 AsyncHelper . RunSync ( ( ) => ValidateSourceAsync ( sourceCreate , options , cancellationToken ) ) ;
32423242
32433243
32443244 /// <inheritdoc />
3245- public async Task < SourceWatchResponse > ValidateSourceBeforeUpdateAsync ( string sourceID , SourceUpdate sourceUpdate , RequestOptions options = null , CancellationToken cancellationToken = default )
3245+ public async Task < WatchResponse > ValidateSourceBeforeUpdateAsync ( string sourceID , SourceUpdate sourceUpdate , RequestOptions options = null , CancellationToken cancellationToken = default )
32463246 {
32473247
32483248 if ( sourceID == null )
@@ -3257,12 +3257,12 @@ public async Task<SourceWatchResponse> ValidateSourceBeforeUpdateAsync(string so
32573257 requestOptions . PathParameters . Add ( "sourceID" , QueryStringHelper . ParameterToString ( sourceID ) ) ;
32583258
32593259 requestOptions . Data = sourceUpdate ;
3260- return await _transport . ExecuteRequestAsync < SourceWatchResponse > ( new HttpMethod ( "POST" ) , "/1/sources/{sourceID}/validate" , requestOptions , cancellationToken ) . ConfigureAwait ( false ) ;
3260+ return await _transport . ExecuteRequestAsync < WatchResponse > ( new HttpMethod ( "POST" ) , "/1/sources/{sourceID}/validate" , requestOptions , cancellationToken ) . ConfigureAwait ( false ) ;
32613261 }
32623262
32633263
32643264 /// <inheritdoc />
3265- public SourceWatchResponse ValidateSourceBeforeUpdate ( string sourceID , SourceUpdate sourceUpdate , RequestOptions options = null , CancellationToken cancellationToken = default ) =>
3265+ public WatchResponse ValidateSourceBeforeUpdate ( string sourceID , SourceUpdate sourceUpdate , RequestOptions options = null , CancellationToken cancellationToken = default ) =>
32663266 AsyncHelper . RunSync ( ( ) => ValidateSourceBeforeUpdateAsync ( sourceID , sourceUpdate , options , cancellationToken ) ) ;
32673267
32683268}
0 commit comments