You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2024/04/03 10:18:02 UTC
(camel) branch CAMEL-20641 created (now 84b8e5e6560)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch CAMEL-20641
in repository https://gitbox.apache.org/repos/asf/camel.git
at 84b8e5e6560 CAMEL-20641 - Camel-AWS-Bedrock-Agent: Add information about failures in ingestion job as header
This branch includes the following new commits:
new e7d7d819ef7 CAMEL-20641 - Camel-AWS-Bedrock-Agent: Add information about failures in ingestion job as header
new 84b8e5e6560 CAMEL-20641 - Camel-AWS-Bedrock-Agent: Add information about failures in ingestion job as header
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(camel) 01/02: CAMEL-20641 - Camel-AWS-Bedrock-Agent: Add information about failures in ingestion job as header
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch CAMEL-20641
in repository https://gitbox.apache.org/repos/asf/camel.git
commit e7d7d819ef7811f1310cd9d3bdb3cec7f076b532
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Apr 3 11:23:11 2024 +0200
CAMEL-20641 - Camel-AWS-Bedrock-Agent: Add information about failures in ingestion job as header
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../aws2/bedrock/agent/BedrockAgentConstants.java | 18 +++++++++++-------
.../agent/BedrockAgentIngestionJobConsumer.java | 3 +++
.../aws2/bedrock/agent/BedrockAgentProducer.java | 3 +++
3 files changed, 17 insertions(+), 7 deletions(-)
diff --git a/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentConstants.java b/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentConstants.java
index 3fd88d8c9c8..459203b9498 100644
--- a/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentConstants.java
+++ b/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentConstants.java
@@ -22,26 +22,30 @@ import org.apache.camel.spi.Metadata;
* Constants used in Camel AWS Bedrock Agent Runtime module SDK v2
*/
public interface BedrockAgentConstants {
- @Metadata(description = "The operation we want to perform", javaType = "String")
+ @Metadata(description = "The operation we want to perform", javaType = "String", label = "producer")
String OPERATION = "CamelAwsBedrockAgentOperation";
@Metadata(description = "The header could be used to set up a model Id dynamically while performing operation",
- javaType = "String")
+ javaType = "String", label = "producer")
String MODEL_ID = "CamelAwsBedrockAgentRuntimeModelId";
@Metadata(description = "The header could be used to set up a data source Id dynamically while performing operation",
- javaType = "String")
+ javaType = "String", label = "producer")
String DATASOURCE_ID = "CamelAwsBedrockAgentDataSourceId";
@Metadata(description = "The header could be used to set up a knowledge base Id dynamically while performing operation",
- javaType = "String")
+ javaType = "String", label = "producer")
String KNOWLEDGE_BASE_ID = "CamelAwsBedrockAgentKnowledgeBaseId";
+ @Metadata(description = "The header contains the id of the ingestion job",
+ javaType = "String", label = "producer")
+ String INGESTION_JOB_ID = "CamelAwsBedrockAgentIngestionJobId";
+
@Metadata(description = "The header contains the status of the ingestion job",
javaType = "String", label = "consumer")
String INGESTION_JOB_STATUS = "CamelAwsBedrockAgentIngestionJobStatus";
- @Metadata(description = "The header contains the id of the ingestion job",
- javaType = "String", label = "producer")
- String INGESTION_JOB_ID = "CamelAwsBedrockAgentIngestionJobId";
+ @Metadata(description = "The header contains the failure reasons of the ingestion job",
+ javaType = "java.util.List", label = "common")
+ String INGESTION_JOB_FAILURE_REASONS = "CamelAwsBedrockAgentIngestionJobFailureReasons";
}
diff --git a/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentIngestionJobConsumer.java b/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentIngestionJobConsumer.java
index a77e597ddb2..a31c1130911 100644
--- a/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentIngestionJobConsumer.java
+++ b/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentIngestionJobConsumer.java
@@ -70,6 +70,9 @@ public class BedrockAgentIngestionJobConsumer extends ScheduledPollConsumer {
Exchange exchange = createExchange(true);
exchange.getMessage().setBody(response.ingestionJob());
exchange.getMessage().setHeader(BedrockAgentConstants.INGESTION_JOB_STATUS, response.ingestionJob().status());
+ if (response.ingestionJob().hasFailureReasons()) {
+ exchange.getMessage().setHeader(BedrockAgentConstants.INGESTION_JOB_FAILURE_REASONS, response.ingestionJob().failureReasons());
+ }
return exchange;
}
}
diff --git a/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentProducer.java b/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentProducer.java
index 42b867189c1..fdc81136524 100644
--- a/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentProducer.java
+++ b/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentProducer.java
@@ -245,6 +245,9 @@ public class BedrockAgentProducer extends DefaultProducer {
private void prepareGetIngestionJobResponse(GetIngestionJobResponse result, Message message) {
message.setBody(result.ingestionJob());
message.setHeader(BedrockAgentConstants.INGESTION_JOB_STATUS, result.ingestionJob().status());
+ if (result.ingestionJob().hasFailureReasons()) {
+ message.setHeader(BedrockAgentConstants.INGESTION_JOB_FAILURE_REASONS, result.ingestionJob().failureReasons());
+ }
}
public static Message getMessageForResponse(final Exchange exchange) {
(camel) 02/02: CAMEL-20641 - Camel-AWS-Bedrock-Agent: Add information about failures in ingestion job as header
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch CAMEL-20641
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 84b8e5e6560abf2bd99f4c26afcf8d9a87be66db
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Apr 3 12:17:28 2024 +0200
CAMEL-20641 - Camel-AWS-Bedrock-Agent: Add information about failures in ingestion job as header
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../camel/component/aws2/bedrock/agent/BedrockAgentConstants.java | 4 ++--
.../aws2/bedrock/agent/BedrockAgentIngestionJobConsumer.java | 3 ++-
2 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentConstants.java b/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentConstants.java
index 459203b9498..4e1fcf44395 100644
--- a/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentConstants.java
+++ b/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentConstants.java
@@ -38,7 +38,7 @@ public interface BedrockAgentConstants {
String KNOWLEDGE_BASE_ID = "CamelAwsBedrockAgentKnowledgeBaseId";
@Metadata(description = "The header contains the id of the ingestion job",
- javaType = "String", label = "producer")
+ javaType = "String", label = "producer")
String INGESTION_JOB_ID = "CamelAwsBedrockAgentIngestionJobId";
@Metadata(description = "The header contains the status of the ingestion job",
@@ -46,6 +46,6 @@ public interface BedrockAgentConstants {
String INGESTION_JOB_STATUS = "CamelAwsBedrockAgentIngestionJobStatus";
@Metadata(description = "The header contains the failure reasons of the ingestion job",
- javaType = "java.util.List", label = "common")
+ javaType = "java.util.List", label = "common")
String INGESTION_JOB_FAILURE_REASONS = "CamelAwsBedrockAgentIngestionJobFailureReasons";
}
diff --git a/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentIngestionJobConsumer.java b/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentIngestionJobConsumer.java
index a31c1130911..d9c9de19be7 100644
--- a/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentIngestionJobConsumer.java
+++ b/components/camel-aws/camel-aws-bedrock/src/main/java/org/apache/camel/component/aws2/bedrock/agent/BedrockAgentIngestionJobConsumer.java
@@ -71,7 +71,8 @@ public class BedrockAgentIngestionJobConsumer extends ScheduledPollConsumer {
exchange.getMessage().setBody(response.ingestionJob());
exchange.getMessage().setHeader(BedrockAgentConstants.INGESTION_JOB_STATUS, response.ingestionJob().status());
if (response.ingestionJob().hasFailureReasons()) {
- exchange.getMessage().setHeader(BedrockAgentConstants.INGESTION_JOB_FAILURE_REASONS, response.ingestionJob().failureReasons());
+ exchange.getMessage().setHeader(BedrockAgentConstants.INGESTION_JOB_FAILURE_REASONS,
+ response.ingestionJob().failureReasons());
}
return exchange;
}