Implement {ConfigFile, ConfigGroup, Chart}#get_resource

Fixes #763.

pkg/gen/python-templates/helm/v2/helm.py

@@ -401,6 +401,11 @@ class Chart(pulumi.ComponentResource):
     none of Tiller's server-side validity testing is executed.
     """
 
+    resources: pulumi.Output[dict]
+    """
+    Kubernetes resources contained in this Chart.
+    """
+
     def __init__(self, release_name, config, opts=None):
         """
         Create an instance of the specified Helm chart.
@@ -420,6 +425,7 @@ def __init__(self, release_name, config, opts=None):
             raise TypeError('Expected resource options to be a ResourceOptions instance')
 
         __props__ = dict()
+        __props__['resources'] = None
 
         if config.resource_prefix:
             release_name = f"{config.resource_prefix}-{release_name}"
@@ -440,5 +446,13 @@ def __init__(self, release_name, config, opts=None):
         # Note: Unlike NodeJS, Python requires that we "pull" on our futures in order to get them scheduled for
         # execution. In order to do this, we leverage the engine's RegisterResourceOutputs to wait for the
         # resolution of all resources that this Helm chart created.
-        resources = all_config.apply(_parse_chart)
-        self.register_outputs({"output": resources})
+        self.resources = all_config.apply(_parse_chart)
+        self.register_outputs({"resources": self.resources})
+
+    def get_resource(self, groupVersionKind: str, namespace=None, name=None) -> pulumi.Output[pulumi.CustomResource]:
+        # `id` will either be `${name}` or `${namespace}/${name}`.
+        id = name
+        if namespace != None:
+            id = f'{namespace}/{name}'
+
+        return self.resources.apply(lambda rs: rs[f'{groupVersionKind}:{id}'])

pkg/gen/python-templates/yaml.py.mustache

@@ -20,6 +20,12 @@ class ConfigFile(pulumi.ComponentResource):
     ConfigFile creates a set of Kubernetes resources from a Kubernetes YAML file.
     """
 
+    resources: pulumi.Output[dict]
+    """
+    Kubernetes resources contained in this ConfigFile.
+    """
+
+
     def __init__(self, name, file_id, opts=None, transformations=None, resource_prefix=None):
         """
         :param str name: A name for a resource.
@@ -38,6 +44,7 @@ class ConfigFile(pulumi.ComponentResource):
             raise TypeError('Expected resource options to be a ResourceOptions instance')
 
         __props__ = dict()
+        __props__['resources'] = None
 
         if resource_prefix:
             name = f"{resource_prefix}-{name}"
@@ -57,8 +64,8 @@ class ConfigFile(pulumi.ComponentResource):
         # Note: Unlike NodeJS, Python requires that we "pull" on our futures in order to get them scheduled for
         # execution. In order to do this, we leverage the engine's RegisterResourceOutputs to wait for the
         # resolution of all resources that this YAML document created.
-        output = _parse_yaml_document(yaml.safe_load_all(text), opts, transformations, resource_prefix)
-        self.register_outputs({"output": output})
+        self.resources = _parse_yaml_document(yaml.safe_load_all(text), opts, transformations, resource_prefix)
+        self.register_outputs({"resources": self.resources})
 
     def translate_output_property(self, prop: str) -> str:
         return tables._CASING_FORWARD_TABLE.get(prop) or prop

sdk/python/pulumi_kubernetes/helm/v2/helm.py

@@ -401,6 +401,11 @@ class Chart(pulumi.ComponentResource):
     none of Tiller's server-side validity testing is executed.
     """
 
+    resources: pulumi.Output[dict]
+    """
+    Kubernetes resources contained in this Chart.
+    """
+
     def __init__(self, release_name, config, opts=None):
         """
         Create an instance of the specified Helm chart.
@@ -420,6 +425,7 @@ def __init__(self, release_name, config, opts=None):
             raise TypeError('Expected resource options to be a ResourceOptions instance')
 
         __props__ = dict()
+        __props__['resources'] = None
 
         if config.resource_prefix:
             release_name = f"{config.resource_prefix}-{release_name}"
@@ -440,5 +446,13 @@ def __init__(self, release_name, config, opts=None):
         # Note: Unlike NodeJS, Python requires that we "pull" on our futures in order to get them scheduled for
         # execution. In order to do this, we leverage the engine's RegisterResourceOutputs to wait for the
         # resolution of all resources that this Helm chart created.
-        resources = all_config.apply(_parse_chart)
-        self.register_outputs({"output": resources})
+        self.resources = all_config.apply(_parse_chart)
+        self.register_outputs({"resources": self.resources})
+
+    def get_resource(self, groupVersionKind: str, namespace=None, name=None) -> pulumi.Output[pulumi.CustomResource]:
+        # `id` will either be `${name}` or `${namespace}/${name}`.
+        id = name
+        if namespace != None:
+            id = f'{namespace}/{name}'
+
+        return self.resources.apply(lambda rs: rs[f'{groupVersionKind}:{id}'])

sdk/python/pulumi_kubernetes/yaml.py

@@ -20,6 +20,12 @@ class ConfigFile(pulumi.ComponentResource):
     ConfigFile creates a set of Kubernetes resources from a Kubernetes YAML file.
     """
 
+    resources: pulumi.Output[dict]
+    """
+    Kubernetes resources contained in this ConfigFile.
+    """
+
+
     def __init__(self, name, file_id, opts=None, transformations=None, resource_prefix=None):
         """
         :param str name: A name for a resource.
@@ -38,6 +44,7 @@ def __init__(self, name, file_id, opts=None, transformations=None, resource_pref
             raise TypeError('Expected resource options to be a ResourceOptions instance')
 
         __props__ = dict()
+        __props__['resources'] = None
 
         if resource_prefix:
             name = f"{resource_prefix}-{name}"
@@ -57,8 +64,8 @@ def __init__(self, name, file_id, opts=None, transformations=None, resource_pref
         # Note: Unlike NodeJS, Python requires that we "pull" on our futures in order to get them scheduled for
         # execution. In order to do this, we leverage the engine's RegisterResourceOutputs to wait for the
         # resolution of all resources that this YAML document created.
-        output = _parse_yaml_document(yaml.safe_load_all(text), opts, transformations, resource_prefix)
-        self.register_outputs({"output": output})
+        self.resources = _parse_yaml_document(yaml.safe_load_all(text), opts, transformations, resource_prefix)
+        self.register_outputs({"resources": self.resources})
 
     def translate_output_property(self, prop: str) -> str:
         return tables._CASING_FORWARD_TABLE.get(prop) or prop