Pull in pulumi/pulumi changes

- CustomResource can now pass Input[str] for id
- Update get test's pulumi/pulumi dep to use the change

pkg/gen/python-templates/CustomResource.py

@@ -75,11 +75,8 @@ def get(resource_name: str,
         :param Optional[ResourceOptions] opts: A bag of options that control this resource's behavior.
         """
 
-        def _unwrap(id):
-            _opts = ResourceOptions(id=id) if opts is None else opts.merge(ResourceOptions(id=id))
-            return CustomResource(resource_name=resource_name, api_version=api_version, kind=kind, opts=_opts)
-
-        return pulumi.Output.from_input(id).apply(_unwrap)
+        opts = ResourceOptions(id=id) if opts is None else opts.merge(ResourceOptions(id=id))
+        return CustomResource(resource_name=resource_name, api_version=api_version, kind=kind, opts=opts)
 
     def translate_output_property(self, prop: str) -> str:
         return tables._CASING_FORWARD_TABLE.get(prop) or prop

sdk/python/pulumi_kubernetes/apiextensions/CustomResource.py

@@ -75,11 +75,8 @@ def get(resource_name: str,
         :param Optional[ResourceOptions] opts: A bag of options that control this resource's behavior.
         """
 
-        def _unwrap(id):
-            _opts = ResourceOptions(id=id) if opts is None else opts.merge(ResourceOptions(id=id))
-            return CustomResource(resource_name=resource_name, api_version=api_version, kind=kind, opts=_opts)
-
-        return pulumi.Output.from_input(id).apply(_unwrap)
+        opts = ResourceOptions(id=id) if opts is None else opts.merge(ResourceOptions(id=id))
+        return CustomResource(resource_name=resource_name, api_version=api_version, kind=kind, opts=opts)
 
     def translate_output_property(self, prop: str) -> str:
         return tables._CASING_FORWARD_TABLE.get(prop) or prop

tests/examples/python/get/requirements.txt

@@ -1 +1 @@
-pulumi>=0.17.1,<2.0.0
+pulumi==1.0.1a1566328728

tests/examples/python/python_test.go

@@ -64,7 +64,8 @@ func TestGet(t *testing.T) {
 		t.FailNow()
 	}
 	options := baseOptions.With(integration.ProgramTestOptions{
-		Dir: filepath.Join(cwd, "get"),
+		ExpectRefreshChanges: true, // CRD changes on refresh
+		Dir:                  filepath.Join(cwd, "get"),
 	})
 	integration.ProgramTest(t, &options)
 }