Fix NoSuchFileException cause by PREFIX directory does not created.

crossroad0201 · Jan 17, 2017 · 5d291f2 · 5d291f2
1 parent 28c1a9c
commit 5d291f2
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/build.sbt b/build.sbt
@@ -2,7 +2,7 @@
 lazy val flywayAwsLambda = (project in file(".")).settings(
   organization := "crossroad0201.aws",
   name := "flyway-awslambda",
-  version := "0.2.0",
+  version := "0.2.1-SNAPSHOT",
   scalaVersion := "2.12.0",
 
   assemblyJarName := s"${name.value}-${version.value}.jar",

diff --git a/src/main/scala/crossroad0201/aws/flywaylambda/deploy/S3SourceFlywayDeployer.scala b/src/main/scala/crossroad0201/aws/flywaylambda/deploy/S3SourceFlywayDeployer.scala
@@ -18,6 +18,7 @@ class S3SourceFlywayDeployer(s3Client: AmazonS3, srcBucketName: String, srcPrefi
     val logger = context.getLogger
 
     val tmpDir = Files.createDirectories(Paths.get("/tmp", context.getAwsRequestId))
+    Files.createDirectories(Paths.get(tmpDir.toString, srcPrefix))
 
     @tailrec
     def deployInternal(objects: List[S3ObjectSummary], acc: (Option[JProperties], ListBuffer[Path])): (Option[JProperties], Seq[Path]) = {
@@ -61,6 +62,9 @@ class S3SourceFlywayDeployer(s3Client: AmazonS3, srcBucketName: String, srcPrefi
         x.getKey.compareTo(y.getKey) < 1
       }
     }
+
+    logger.log(s"Deploying Flyway resources from $srcBucketName/$srcPrefix... ${objectSummaries.map(_.getKey).mkString(", ")}")
+
     deployInternal(objectSummaries, (None, ListBuffer())) match {
       case (Some(conf), sqlFiles) =>
         FlywayDeployment(