This is an automated email from the ASF dual-hosted git repository. emergentorder pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/predictionio.git
commit 1094de8322285a572b2d2e8ae49073d1066242d2 Author: Alex Merritt <[email protected]> AuthorDate: Thu Jul 25 19:19:01 2019 -0300 Set engine id, version, variant, even in Python --- tools/src/main/scala/org/apache/predictionio/tools/RunWorkflow.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/tools/src/main/scala/org/apache/predictionio/tools/RunWorkflow.scala b/tools/src/main/scala/org/apache/predictionio/tools/RunWorkflow.scala index 50b9337..701a3ee 100644 --- a/tools/src/main/scala/org/apache/predictionio/tools/RunWorkflow.scala +++ b/tools/src/main/scala/org/apache/predictionio/tools/RunWorkflow.scala @@ -52,14 +52,14 @@ object RunWorkflow extends Logging { val jarFiles = jarFilesForScala(engineDirPath).map(_.toURI) val args = - (if (wa.mainPyFile.isEmpty) { + { val variantJson = wa.variantJson.getOrElse(new File(engineDirPath, "engine.json")) val ei = Console.getEngineInfo(variantJson, engineDirPath) Seq( "--engine-id", ei.engineId, "--engine-version", ei.engineVersion, "--engine-variant", variantJson.toURI.toString) - } else Nil) ++ + } ++ wa.engineFactory.map( x => Seq("--engine-factory", x)).getOrElse(Nil) ++ wa.engineParamsKey.map(
