Skip to content

Commit

Permalink
Fix input loading for sync import
Browse files Browse the repository at this point in the history
Signed-off-by: Ansari, Mujammil <[email protected]>
  • Loading branch information
mujammil10 authored and roegi committed Sep 24, 2024
1 parent 91f232f commit 90f4b20
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -353,7 +353,7 @@ private void syncExecution() throws WebClientException, SQLException, TooManyRes
long newVersion = increaseVersionSequence();
long featureCount = 0;

for (Input input : loadInputs()) {
for (S3DataFile input : loadStepInputs()) {
logger.info("[{}] Sync write from {} to {}", getGlobalStepId(), input.getS3Key(), getSpaceId());
featureCount += syncWriteFileToSpace(input, newVersion);
}
Expand All @@ -368,7 +368,7 @@ private void syncExecution() throws WebClientException, SQLException, TooManyRes
* @param newVersion The new space version being created by this import
* @return The number of features that have been written
*/
private int syncWriteFileToSpace(Input input, long newVersion)
private int syncWriteFileToSpace(S3DataFile input, long newVersion)
throws IOException, WebClientException, SQLException, TooManyResourcesClaimed {
final S3Client s3Client = S3Client.getInstance(input.getS3Bucket());

Expand Down

0 comments on commit 90f4b20

Please sign in to comment.