From 9cf8c6cec30f5a874d3001989de870f8f2c6b25b Mon Sep 17 00:00:00 2001 From: Christopher Grote Date: Fri, 22 Nov 2024 09:12:19 +0000 Subject: [PATCH] Correct downloads for GCS and ADLS deltas --- .../src/main/kotlin/com/atlan/pkg/objectstore/ADLSSync.kt | 2 +- .../src/main/kotlin/com/atlan/pkg/objectstore/GCSSync.kt | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/package-toolkit/runtime/src/main/kotlin/com/atlan/pkg/objectstore/ADLSSync.kt b/package-toolkit/runtime/src/main/kotlin/com/atlan/pkg/objectstore/ADLSSync.kt index 3cb09f067f..75987189df 100644 --- a/package-toolkit/runtime/src/main/kotlin/com/atlan/pkg/objectstore/ADLSSync.kt +++ b/package-toolkit/runtime/src/main/kotlin/com/atlan/pkg/objectstore/ADLSSync.kt @@ -156,7 +156,7 @@ class ADLSSync( if (latestFileKey.isNotBlank()) { val local = File(localDirectory, latestFileKey).path downloadFrom( - latestFileKey, + File(prefix, latestFileKey).path, local, ) local diff --git a/package-toolkit/runtime/src/main/kotlin/com/atlan/pkg/objectstore/GCSSync.kt b/package-toolkit/runtime/src/main/kotlin/com/atlan/pkg/objectstore/GCSSync.kt index 561ff428e9..6a7dbdc75e 100644 --- a/package-toolkit/runtime/src/main/kotlin/com/atlan/pkg/objectstore/GCSSync.kt +++ b/package-toolkit/runtime/src/main/kotlin/com/atlan/pkg/objectstore/GCSSync.kt @@ -104,7 +104,7 @@ class GCSSync( if (latestFileKey.isNotBlank()) { val local = File(localDirectory, latestFileKey).path downloadFrom( - latestFileKey, + File(prefix, latestFileKey).path, local, ) local