wip

TouK · Jan 17, 2025 · 81d95d8 · 81d95d8
1 parent 3ac7e6e
commit 81d95d8
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/...xecutor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala b/...xecutor/src/main/scala/pl/touk/nussknacker/engine/process/runner/FlinkStubbedRunner.scala
@@ -75,7 +75,7 @@ final class FlinkStubbedRunner(modelClassLoader: ModelClassLoader, configuration
     // see details in pl.touk.nussknacker.engine.flink.test.MiniClusterExecutionEnvironment#execute
     modelClassLoader.urls match {
       // FIXME abr: is it necessary?
-      case Nil =>
+//      case Nil =>
 //        ConfigUtils.decodeListFromConfig[String, URL, MalformedURLException](
 //          configuration,
 //          PipelineOptions.CLASSPATHS,

diff --git a/...executor/src/test/scala/pl/touk/nussknacker/engine/process/runner/FlinkTestMainSpec.scala b/...executor/src/test/scala/pl/touk/nussknacker/engine/process/runner/FlinkTestMainSpec.scala
@@ -41,11 +41,13 @@ import pl.touk.nussknacker.engine.testmode.TestProcess._
 import pl.touk.nussknacker.engine.util.ThreadUtils
 import pl.touk.nussknacker.engine.{ModelConfigs, ModelData}
 import pl.touk.nussknacker.engine.deployment.AdditionalModelConfigs
+import pl.touk.nussknacker.engine.testing.LocalModelData
 
 import java.util.{Date, UUID}
 import scala.concurrent.ExecutionContext.Implicits.global
 import scala.concurrent.duration._
 import scala.concurrent.{Await, Future}
+import scala.jdk.CollectionConverters._
 
 class FlinkTestMainSpec extends AnyWordSpec with Matchers with Inside with BeforeAndAfterEach with OptionValues {
 
@@ -765,6 +767,10 @@ class FlinkTestMainSpec extends AnyWordSpec with Matchers with Inside with Befor
   ): TestResults[_] = {
     val config = enrichDefaultConfig(ConfigFactory.load("application.conf"))
       .withValue("globalParameters.useIOMonadInInterpreter", ConfigValueFactory.fromAnyRef(useIOMonadInInterpreter))
+      .withValue(
+        "classpath",
+        ConfigValueFactory.fromIterable(FlinkTestConfiguration.classpathWorkaround.map(_.toString).asJava)
+      )
 
     // We need to set context loader to avoid forking in sbt
     val modelData = ModelData.duringFlinkExecution(