Skip to content

Commit a1f0a60

Browse files
committed
Update document-grounding based on main
1 parent 8751f95 commit a1f0a60

File tree

8 files changed

+1100
-0
lines changed

8 files changed

+1100
-0
lines changed

core-services/document-grounding/src/main/java/com/sap/ai/sdk/grounding/client/PipelinesApi.java

Lines changed: 68 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88
import com.sap.ai.sdk.grounding.model.GetPipelineExecutions;
99
import com.sap.ai.sdk.grounding.model.GetPipelineStatus;
1010
import com.sap.ai.sdk.grounding.model.GetPipelines;
11+
import com.sap.ai.sdk.grounding.model.ManualPipelineTrigger;
1112
import com.sap.ai.sdk.grounding.model.PipelineDocumentResponse;
1213
import com.sap.ai.sdk.grounding.model.PipelineId;
1314
import com.sap.cloud.sdk.cloudplatform.connectivity.Destination;
@@ -1002,4 +1003,71 @@ public GetPipelineStatus getPipelineStatus(
10021003
localVarAuthNames,
10031004
localVarReturnType);
10041005
}
1006+
1007+
/**
1008+
* Pipeline Trigger
1009+
*
1010+
* <p>Manually trigger a pipeline
1011+
*
1012+
* <p><b>202</b> - Accepted
1013+
*
1014+
* <p><b>400</b> - The specification of the resource was incorrect
1015+
*
1016+
* @param aiResourceGroup Resource Group ID
1017+
* @param body The value for the parameter body
1018+
* @return An OpenApiResponse containing the status code of the HttpResponse.
1019+
* @throws OpenApiRequestException if an error occurs while attempting to invoke the API
1020+
*/
1021+
@Nonnull
1022+
public OpenApiResponse manualTriggerPipeline(
1023+
@Nonnull final String aiResourceGroup, @Nonnull final ManualPipelineTrigger body)
1024+
throws OpenApiRequestException {
1025+
final Object localVarPostBody = body;
1026+
1027+
// verify the required parameter 'aiResourceGroup' is set
1028+
if (aiResourceGroup == null) {
1029+
throw new OpenApiRequestException(
1030+
"Missing the required parameter 'aiResourceGroup' when calling manualTriggerPipeline");
1031+
}
1032+
1033+
// verify the required parameter 'body' is set
1034+
if (body == null) {
1035+
throw new OpenApiRequestException(
1036+
"Missing the required parameter 'body' when calling pipelineV1PipelineEndpointsTriggerPipeline");
1037+
}
1038+
1039+
final String localVarPath =
1040+
UriComponentsBuilder.fromPath("/pipelines/trigger").build().toUriString();
1041+
1042+
final MultiValueMap<String, String> localVarQueryParams =
1043+
new LinkedMultiValueMap<String, String>();
1044+
final HttpHeaders localVarHeaderParams = new HttpHeaders();
1045+
final MultiValueMap<String, Object> localVarFormParams =
1046+
new LinkedMultiValueMap<String, Object>();
1047+
1048+
if (aiResourceGroup != null)
1049+
localVarHeaderParams.add("AI-Resource-Group", apiClient.parameterToString(aiResourceGroup));
1050+
1051+
final String[] localVarAccepts = {"application/json"};
1052+
final List<MediaType> localVarAccept = apiClient.selectHeaderAccept(localVarAccepts);
1053+
final String[] localVarContentTypes = {"application/json"};
1054+
final MediaType localVarContentType = apiClient.selectHeaderContentType(localVarContentTypes);
1055+
1056+
final String[] localVarAuthNames = new String[] {};
1057+
1058+
final ParameterizedTypeReference<Void> localVarReturnType =
1059+
new ParameterizedTypeReference<Void>() {};
1060+
apiClient.invokeAPI(
1061+
localVarPath,
1062+
HttpMethod.POST,
1063+
localVarQueryParams,
1064+
localVarPostBody,
1065+
localVarHeaderParams,
1066+
localVarFormParams,
1067+
localVarAccept,
1068+
localVarContentType,
1069+
localVarAuthNames,
1070+
localVarReturnType);
1071+
return new OpenApiResponse(apiClient);
1072+
}
10051073
}

core-services/document-grounding/src/main/java/com/sap/ai/sdk/grounding/model/CreatePipeline.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,12 +19,18 @@
1919
@JsonSubTypes({
2020
@JsonSubTypes.Type(value = MSSharePointPipelineCreateRequest.class, name = "MSSharePoint"),
2121
@JsonSubTypes.Type(value = S3PipelineCreateRequest.class, name = "S3"),
22+
@JsonSubTypes.Type(value = SDMPipelineCreateRequest.class, name = "SDM"),
2223
@JsonSubTypes.Type(value = SFTPPipelineCreateRequest.class, name = "SFTP"),
24+
@JsonSubTypes.Type(value = WorkZonePipelineCreateRequest.class, name = "WorkZone"),
2325
@JsonSubTypes.Type(
2426
value = MSSharePointPipelineCreateRequest.class,
2527
name = "MSSharePointPipelineCreateRequest"),
2628
@JsonSubTypes.Type(value = S3PipelineCreateRequest.class, name = "S3PipelineCreateRequest"),
29+
@JsonSubTypes.Type(value = SDMPipelineCreateRequest.class, name = "SDMPipelineCreateRequest"),
2730
@JsonSubTypes.Type(value = SFTPPipelineCreateRequest.class, name = "SFTPPipelineCreateRequest"),
31+
@JsonSubTypes.Type(
32+
value = WorkZonePipelineCreateRequest.class,
33+
name = "WorkZonePipelineCreateRequest"),
2834
})
2935
public interface CreatePipeline {
3036
Object getType();

core-services/document-grounding/src/main/java/com/sap/ai/sdk/grounding/model/DocumentStatus.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,8 @@ public enum DocumentStatus {
2929

3030
FAILED_TO_BE_RETRIED("FAILED_TO_BE_RETRIED"),
3131

32+
TO_BE_SCHEDULED("TO_BE_SCHEDULED"),
33+
3234
UNKNOWN_DEFAULT_OPEN_API("unknown_default_open_api");
3335

3436
private final String value;

core-services/document-grounding/src/main/java/com/sap/ai/sdk/grounding/model/GetPipeline.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,12 +19,18 @@
1919
@JsonSubTypes({
2020
@JsonSubTypes.Type(value = MSSharePointPipelineGetResponse.class, name = "MSSharePoint"),
2121
@JsonSubTypes.Type(value = S3PipelineGetResponse.class, name = "S3"),
22+
@JsonSubTypes.Type(value = SDMPipelineGetResponse.class, name = "SDM"),
2223
@JsonSubTypes.Type(value = SFTPPipelineGetResponse.class, name = "SFTP"),
24+
@JsonSubTypes.Type(value = WorkZonePipelineGetResponse.class, name = "WorkZone"),
2325
@JsonSubTypes.Type(
2426
value = MSSharePointPipelineGetResponse.class,
2527
name = "MSSharePointPipelineGetResponse"),
2628
@JsonSubTypes.Type(value = S3PipelineGetResponse.class, name = "S3PipelineGetResponse"),
29+
@JsonSubTypes.Type(value = SDMPipelineGetResponse.class, name = "SDMPipelineGetResponse"),
2730
@JsonSubTypes.Type(value = SFTPPipelineGetResponse.class, name = "SFTPPipelineGetResponse"),
31+
@JsonSubTypes.Type(
32+
value = WorkZonePipelineGetResponse.class,
33+
name = "WorkZonePipelineGetResponse"),
2834
})
2935
public interface GetPipeline {
3036
Object getType();

0 commit comments

Comments
 (0)