Prototype for Syncing Verisons with constants.py

src/_nebari/constants.py

@@ -35,3 +35,22 @@
 AZURE_DEFAULT_REGION = "Central US"
 GCP_DEFAULT_REGION = "us-central1"
 DO_DEFAULT_REGION = "nyc3"
+
+# TERRAFORM REQUIRED PROVIDERS
+REQUIRED_PROVIDERS = {
+    "null": {
+        "_name": "null",
+        "source": "hashicorp/null",
+        "version": "3.2.3",
+    },
+    "helm": {
+        "_name": "helm",
+        "source": "hashicorp/helm",
+        "version": "2.1.2",
+    },
+    "kubernetes": {
+        "_name": "kubernetes",
+        "source": "hashicorp/kubernetes",
+        "version": "2.20.0",
+    },
+}

src/_nebari/stages/base.py

@@ -65,7 +65,6 @@ def set_outputs(
     def check(
         self, stage_outputs: Dict[str, Dict[str, Any]], disable_prompt: bool = False
     ):
-
         if self.failed_to_create:
             print(
                 f"ERROR: After stage={self.name} "
@@ -143,7 +142,6 @@ def render(self) -> Dict[pathlib.Path, str]:
     def deploy(
         self, stage_outputs: Dict[str, Dict[str, Any]], disable_prompt: bool = False
     ):
-
         print(f"Deploying kubernetes resources for {self.name}")
         # get the kubernetes client
         kubernetes_client = self._get_k8s_client(stage_outputs)
@@ -208,7 +206,6 @@ def destroy(
         # destroy each manifest in the reverse order
 
         for manifest in sorted(manifests, reverse=True):
-
             print(f"Destroyed manifest: {manifest}")
             try:
                 kubernetes.delete_from_yaml(kubernetes_client, manifest)
@@ -220,7 +217,6 @@ def destroy(
         # destroy each crd in the reverse order
 
         for crd in sorted(crds, reverse=True):
-
             print(f"Destroyed CRD: {crd}")
             try:
                 kubernetes.delete_from_yaml(kubernetes_client, crd)

src/_nebari/stages/kubernetes_initialize/__init__.py

@@ -7,7 +7,8 @@
 from _nebari.stages.tf_objects import (
     NebariHelmProvider,
     NebariKubernetesProvider,
-    NebariTerraformState,
+    NebariTerraformRequiredProvider,
+    NebariTerraformRequiredVersion,
 )
 from nebari import schema
 from nebari.hookspecs import NebariStage, hookimpl
@@ -64,7 +65,10 @@ class KubernetesInitializeStage(NebariTerraformStage):
 
     def tf_objects(self) -> List[Dict]:
         return [
-            NebariTerraformState(self.name, self.config),
+            *super().tf_objects(),
+            NebariTerraformRequiredVersion(self.config),
+            NebariTerraformRequiredProvider("helm", self.config),
+            NebariTerraformRequiredProvider("kubernetes", self.config),
             NebariKubernetesProvider(self.config),
             NebariHelmProvider(self.config),
         ]

src/_nebari/stages/kubernetes_initialize/template/versions.tf

@@ -1,13 +1,13 @@
-terraform {
-  required_providers {
-    helm = {
-      source  = "hashicorp/helm"
-      version = "2.1.2"
-    }
-    kubernetes = {
-      source  = "hashicorp/kubernetes"
-      version = "2.20.0"
-    }
-  }
-  required_version = ">= 1.0"
-}
+# terraform {
+#   required_providers {
+#     helm = {
+#       source  = "hashicorp/helm"
+#       version = "2.1.2"
+#     }
+#     kubernetes = {
+#       source  = "hashicorp/kubernetes"
+#       version = "2.20.0"
+#     }
+#   }
+#   required_version = ">= 1.0"
+# }

src/_nebari/stages/terraform_state/__init__.py

@@ -12,7 +12,11 @@
 from _nebari.provider import terraform
 from _nebari.provider.cloud import azure_cloud
 from _nebari.stages.base import NebariTerraformStage
-from _nebari.stages.tf_objects import NebariConfig
+from _nebari.stages.tf_objects import (
+    NebariConfig,
+    NebariTerraformRequiredProvider,
+    NebariTerraformRequiredVersion,
+)
 from _nebari.utils import (
     AZURE_TF_STATE_RESOURCE_GROUP_SUFFIX,
     construct_azure_resource_group_name,
@@ -172,7 +176,11 @@ def state_imports(self) -> List[Tuple[str, str]]:
             return []
 
     def tf_objects(self) -> List[Dict]:
-        resources = [NebariConfig(self.config)]
+        resources = [
+            NebariConfig(self.config),
+            NebariTerraformRequiredProvider("null", self.config),
+            NebariTerraformRequiredVersion(self.config),
+        ]
         if self.config.provider == schema.ProviderEnum.gcp:
             return resources + [
                 terraform.Provider(

src/_nebari/stages/tf_objects.py

@@ -1,4 +1,12 @@
-from _nebari.provider.terraform import Data, Provider, Resource, TerraformBackend
+from _nebari import constants
+from _nebari.provider.terraform import (
+    Data,
+    Provider,
+    RequiredProvider,
+    Resource,
+    Terraform,
+    TerraformBackend,
+)
 from _nebari.utils import (
     AZURE_TF_STATE_RESOURCE_GROUP_SUFFIX,
     construct_azure_resource_group_name,
@@ -117,5 +125,13 @@ def NebariTerraformState(directory: str, nebari_config: schema.Main):
         raise NotImplementedError("state not implemented")
 
 
+def NebariTerraformRequiredProvider(name: str, nebari_config: schema.Main):
+    return RequiredProvider(**constants.REQUIRED_PROVIDERS[name])
+
+
+def NebariTerraformRequiredVersion(nebari_config: schema.Main):
+    return Terraform(required_version=constants.TERRAFORM_VERSION)
+
+
 def NebariConfig(nebari_config: schema.Main):
     return Resource("terraform_data", "nebari_config", input=nebari_config.model_dump())