put kafka service behind protections again

Enterprise-CMCS · Dec 18, 2024 · 0fde9b8 · 0fde9b8
1 parent a404b6a
commit 0fde9b8
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/src/run.ts b/src/run.ts
@@ -161,10 +161,9 @@ async function deploy(options: { stage: string }) {
   const deployCmd = ["sls", "deploy", "--stage", stage];
   await runner.run_command_and_output("SLS Deploy", deployCmd, ".");
   // Only deploy resources for kafka ingestion in real envs
-
-  // if (stage === "main" || stage === "val" || stage === "production") {
-  await deploy_kafka_service(runner, stage);
-  // }
+  if (stage === "main" || stage === "val" || stage === "production") {
+    await deploy_kafka_service(runner, stage);
+  }
 }
 
 async function destroy_stage(options: {