(nifi) branch main updated: NIFI-15457 Fixed awsTaskId FlowFile attribute in AWS Machine Learning Processors (#10760)

[exceptionfactory]

This is an automated email from the ASF dual-hosted git repository.

exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


The following commit(s) were added to refs/heads/main by this push:
     new 641cbe4de0 NIFI-15457 Fixed awsTaskId FlowFile attribute in AWS 
Machine Learning Processors (#10760)
641cbe4de0 is described below

commit 641cbe4de0fe169412c7502ae0b114ad6fed0aca
Author: Balázs Gerner <balazsger...@gmail.com>
AuthorDate: Mon Jan 12 23:21:17 2026 +0100

    NIFI-15457 Fixed awsTaskId FlowFile attribute in AWS Machine Learning 
Processors (#10760)
    
    Signed-off-by: David Handermann <exceptionfact...@apache.org>
---
 .../nifi/processors/aws/ml/AbstractAwsMachineLearningJobStarter.java   | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/ml/AbstractAwsMachineLearningJobStarter.java
 
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/ml/AbstractAwsMachineLearningJobStarter.java
index 759f597754..c05940735e 100644
--- 
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/ml/AbstractAwsMachineLearningJobStarter.java
+++ 
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/ml/AbstractAwsMachineLearningJobStarter.java
@@ -44,7 +44,6 @@ import java.util.List;
 import java.util.Set;
 
 import static org.apache.nifi.flowfile.attributes.CoreAttributes.MIME_TYPE;
-import static 
org.apache.nifi.processors.aws.ml.AbstractAwsMachineLearningJobStatusProcessor.TASK_ID;
 import static org.apache.nifi.processors.aws.region.RegionUtil.CUSTOM_REGION;
 import static org.apache.nifi.processors.aws.region.RegionUtil.REGION;
 
@@ -140,7 +139,7 @@ public abstract class AbstractAwsMachineLearningJobStarter<
 
     protected FlowFile postProcessFlowFile(final ProcessContext context, final 
ProcessSession session, final FlowFile flowFile, final Res response) {
         final String awsTaskId = getAwsTaskId(context, response, flowFile);
-        FlowFile processedFlowFile = session.putAttribute(flowFile, 
TASK_ID.getName(), awsTaskId);
+        FlowFile processedFlowFile = session.putAttribute(flowFile, 
"awsTaskId", awsTaskId);
         processedFlowFile = session.putAttribute(processedFlowFile, 
MIME_TYPE.key(), "application/json");
         getLogger().debug("AWS ML Task [{}] started", awsTaskId);
         return processedFlowFile;