fix

LangStream · May 20, 2024 · 5bc7f2f · 5bc7f2f
1 parent e145b71
commit 5bc7f2f
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 2 deletions.
diff --git a/langstream-core/src/main/java/ai/langstream/impl/deploy/ApplicationDeployer.java b/langstream-core/src/main/java/ai/langstream/impl/deploy/ApplicationDeployer.java
@@ -45,7 +45,7 @@ public final class ApplicationDeployer implements AutoCloseable {
 
     private ClusterRuntimeRegistry registry;
     private PluginsRegistry pluginsRegistry;
-    private DeployContext deployContext;
+    @Builder.Default private DeployContext deployContext = DeployContext.NO_DEPLOY_CONTEXT;
     @Getter private TopicConnectionsRuntimeRegistry topicConnectionsRuntimeRegistry;
     private AssetManagerRegistry assetManagerRegistry;
 

diff --git a/langstream-e2e-tests/src/test/java/ai/langstream/tests/util/BaseEndToEndTest.java b/langstream-e2e-tests/src/test/java/ai/langstream/tests/util/BaseEndToEndTest.java
@@ -1147,7 +1147,13 @@ private static void deployLocalApplicationAndAwaitReady(
         final String tenantNamespace = TENANT_NAMESPACE_PREFIX + tenant;
         final String podUids =
                 deployLocalApplication(
-                        tenant, isUpdate, applicationId, appDirName, instanceFile, env);
+                        tenant,
+                        isUpdate,
+                        applicationId,
+                        appDirName,
+                        instanceFile,
+                        env,
+                        forceRestart);
 
         awaitApplicationReady(applicationId, expectedNumExecutors);
         Awaitility.await()

diff --git a/...eam-pulsar-runtime/src/test/java/ai/langstream/pulsar/PulsarClusterRuntimeDockerTest.java b/...eam-pulsar-runtime/src/test/java/ai/langstream/pulsar/PulsarClusterRuntimeDockerTest.java
@@ -25,6 +25,7 @@
 import ai.langstream.api.model.TopicDefinition;
 import ai.langstream.api.runner.topics.TopicConnectionsRuntimeRegistry;
 import ai.langstream.api.runtime.ClusterRuntimeRegistry;
+import ai.langstream.api.runtime.DeployContext;
 import ai.langstream.api.runtime.ExecutionPlan;
 import ai.langstream.api.runtime.PluginsRegistry;
 import ai.langstream.impl.deploy.ApplicationDeployer;
@@ -73,6 +74,7 @@ public void testMapPulsarTopics() throws Exception {
                         .registry(new ClusterRuntimeRegistry())
                         .pluginsRegistry(new PluginsRegistry())
                         .topicConnectionsRuntimeRegistry(new TopicConnectionsRuntimeRegistry())
+                        .deployContext(DeployContext.NO_DEPLOY_CONTEXT)
                         .build()) {
 
             Module module = applicationInstance.getModule("module-1");