update

lizu18xz · May 22, 2021 · 3c29220 · 3c29220
1 parent f7a3c03
commit 3c29220
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...thon-controller/src/main/java/tech/mlsql/plugins/app/pythoncontroller/PythonInclude.scala b/...thon-controller/src/main/java/tech/mlsql/plugins/app/pythoncontroller/PythonInclude.scala
@@ -33,7 +33,7 @@ class PythonInclude(override val uid: String) extends SQLAlg with VersionCompati
         val newdf = session.createDataset[String](Seq(item))
         newdf.createOrReplaceTempView(tableName)
         newdf.toDF()
-      case Array("local", path, tableName) =>
+      case Array("local", path, "named", tableName) =>
         val includer = new ScriptIncludeSource()
         val pythonCode = includer.fetchSource(session, path, Map())
         val item = JSONTool.toJsonStr(Map("content" -> pythonCode))