From 8c0b229eac85e9fd02cf96b73f3862a2aa491d52 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Benjamin=20R=C3=B6gner?= Date: Fri, 17 Jul 2026 16:48:03 +0200 Subject: [PATCH] MMSUP-2904: Fix issue with loading outputs of GENERIC OutputSets MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - The wrong bucket (default bucket) was used while trying to scan the outputs of a GENERIC output set. Extracted the bucket to be scanned from the according S3 URI Signed-off-by: Benjamin Rögner --- .../src/main/java/com/here/xyz/jobs/steps/Step.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/xyz-jobs/xyz-job-steps/src/main/java/com/here/xyz/jobs/steps/Step.java b/xyz-jobs/xyz-job-steps/src/main/java/com/here/xyz/jobs/steps/Step.java index 89b1169a8b..86a3436459 100644 --- a/xyz-jobs/xyz-job-steps/src/main/java/com/here/xyz/jobs/steps/Step.java +++ b/xyz-jobs/xyz-job-steps/src/main/java/com/here/xyz/jobs/steps/Step.java @@ -252,7 +252,9 @@ private void replaceOutputSet(String outputSetName, OutputSet outputSet) { * @return The outputs that have been registered for the specified outputSet (so far). */ protected List loadStepOutputs(OutputSet outputSet) { - return loadOutputs(defaultBucket(), Set.of(toS3Path(outputSet)), outputSet.modelBased); + //TODO: Refactor S3Client to be bucket-agnostic + S3Uri s3Uri = outputSet.toS3Uri(getJobId()); + return loadOutputs(s3Uri.bucket(), Set.of(s3Uri.key()), outputSet.modelBased); } private List loadOutputs(String bucketName, Set s3Prefixes, boolean modelBased) { @@ -355,6 +357,7 @@ private List loadInputs(InputSet inputSet) { * @return All outputs for the specified InputSet */ private List loadOutputsFor(InputSet inputSet) { + //TODO: Refactor S3Client to be bucket-agnostic S3Uri s3Uri = inputSet.toS3Uri(jobId); return loadOutputs(s3Uri.bucket(), Set.of(s3Uri.key()), inputSet.modelBased()); }