Skip to content

Commit

Permalink
minor refactoring
Browse files Browse the repository at this point in the history
  • Loading branch information
pvighi committed Nov 28, 2018
1 parent ae0696c commit 928199c
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ object DownloadBatchHandler {
jobId: String,
batches: List[WireBatchInfo],
uploadToDataLake: Boolean,
done: Boolean = false,
done: Boolean = false
)

object WireState {
Expand Down Expand Up @@ -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 {
Expand Down

0 comments on commit 928199c

Please sign in to comment.