From 928199c3cd8ee1ea5bf65e4092a9a7b86bad48fe Mon Sep 17 00:00:00 2001 From: pvighi Date: Wed, 28 Nov 2018 12:29:26 +0000 Subject: [PATCH] minor refactoring --- .../gu/sf_datalake_export/handlers/DownloadBatchHandler.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/handlers/sf-datalake-export/src/main/scala/com/gu/sf_datalake_export/handlers/DownloadBatchHandler.scala b/handlers/sf-datalake-export/src/main/scala/com/gu/sf_datalake_export/handlers/DownloadBatchHandler.scala index b0315ca332..4e95a98b47 100644 --- a/handlers/sf-datalake-export/src/main/scala/com/gu/sf_datalake_export/handlers/DownloadBatchHandler.scala +++ b/handlers/sf-datalake-export/src/main/scala/com/gu/sf_datalake_export/handlers/DownloadBatchHandler.scala @@ -53,7 +53,7 @@ object DownloadBatchHandler { jobId: String, batches: List[WireBatchInfo], uploadToDataLake: Boolean, - done: Boolean = false, + done: Boolean = false ) object WireState { @@ -153,7 +153,7 @@ object DownloadBatchHandler { getUploadPath: (ObjectName, ShouldUploadToDataLake) => S3Path, downloadBatch: (JobName, JobId, BatchId, S3Path) => Try[Unit] )(currentState: State): Try[State] = { - //todo see how to refactor this + def downloadFirstBatch(uploadBasePath: S3Path) = { val downloadableBatches = currentState.batches.filter(_.state == Completed) downloadableBatches match {