Merge pull request #1041 from atlanhq/FT-786

cmgrote · web-flow · commit 8ee3fef57f66 · 2024-11-22T09:20:12.000Z
Correct downloads for GCS and ADLS deltas
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
@@ -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
@@ -104,7 +104,7 @@ class GCSSync(
             if (latestFileKey.isNotBlank()) {
                 val local = File(localDirectory, latestFileKey).path
                 downloadFrom(
-                    latestFileKey,
+                    File(prefix, latestFileKey).path,
                     local,
                 )
                 local

Original file line number	Diff line number	Diff line change
`@@ -156,7 +156,7 @@ class ADLSSync(`
`156`	`156`	`if (latestFileKey.isNotBlank()) {`
`157`	`157`	`val local = File(localDirectory, latestFileKey).path`
`158`	`158`	`downloadFrom(`
`159`		`- latestFileKey,`
	`159`	`+ File(prefix, latestFileKey).path,`
`160`	`160`	`local,`
`161`	`161`	`)`
`162`	`162`	`local`
Original file line number	Diff line number	Diff line change
`@@ -104,7 +104,7 @@ class GCSSync(`
`104`	`104`	`if (latestFileKey.isNotBlank()) {`
`105`	`105`	`val local = File(localDirectory, latestFileKey).path`
`106`	`106`	`downloadFrom(`
`107`		`- latestFileKey,`
	`107`	`+ File(prefix, latestFileKey).path,`
`108`	`108`	`local,`
`109`	`109`	`)`
`110`	`110`	`local`