Upgrade tf-bridge to v3.40.0 and p/p to v3.53.1 (#2366)

provider/go.mod

@@ -7,9 +7,9 @@ require (
 	github.com/hashicorp/aws-sdk-go-base/v2 v2.0.0-beta.21
 	github.com/hashicorp/terraform-provider-aws/shim v0.0.0
 	github.com/mitchellh/go-homedir v1.1.0
-	github.com/pulumi/pulumi-terraform-bridge/v3 v3.38.1-0.20230120171240-d55a6d77f8d1
-	github.com/pulumi/pulumi/pkg/v3 v3.51.0
-	github.com/pulumi/pulumi/sdk/v3 v3.51.0
+	github.com/pulumi/pulumi-terraform-bridge/v3 v3.40.0
+	github.com/pulumi/pulumi/pkg/v3 v3.53.1
+	github.com/pulumi/pulumi/sdk/v3 v3.53.1
 )
 
 replace (

provider/go.sum

@@ -1592,14 +1592,14 @@ github.com/prometheus/prometheus v0.37.0/go.mod h1:egARUgz+K93zwqsVIAneFlLZefyGO
 github.com/prometheus/tsdb v0.7.1/go.mod h1:qhTCs0VvXwvX/y3TZrWD7rabWM+ijKTux40TwIPHuXU=
 github.com/pulumi/pulumi-java/pkg v0.7.1 h1:3tl36+I5BRYVXbq10mqDeh3X5kdJBaNDYiATOfEfgSY=
 github.com/pulumi/pulumi-java/pkg v0.7.1/go.mod h1:XdN2jYNlcQewr0MFecZfBnY3gnGcvV+WoPTzQqH48k4=
-github.com/pulumi/pulumi-terraform-bridge/v3 v3.38.1-0.20230120171240-d55a6d77f8d1 h1:J+bVW67aYYhU7la96PJYRxOy5tQbxuh4wgd/DTY85N8=
-github.com/pulumi/pulumi-terraform-bridge/v3 v3.38.1-0.20230120171240-d55a6d77f8d1/go.mod h1:RC9XOYwRU6c+1TtZKwwzpojz6POHz8Mbtx9qZcU+lPA=
+github.com/pulumi/pulumi-terraform-bridge/v3 v3.40.0 h1:8rKlkIwxJ16DmmgVCb15aB95yl25UVXSQm9nvWZkf30=
+github.com/pulumi/pulumi-terraform-bridge/v3 v3.40.0/go.mod h1:McH/PLanWyrObVQIPwwZAffK26hxNXQScjp6NyGibpo=
 github.com/pulumi/pulumi-yaml v1.0.4 h1:p+989rW3AqkkxbzxtxccHKAN4xCJi3K2cRpvA2K84tw=
 github.com/pulumi/pulumi-yaml v1.0.4/go.mod h1:Szj8ud4Vqyq3oO1n3kzIUfaP3AiCjYZM4FYjOVWwJn8=
-github.com/pulumi/pulumi/pkg/v3 v3.51.0 h1:FAgWGex4SIMvu3wCIoANjhI4uEUXk4IgHM/HMVZnZ0M=
-github.com/pulumi/pulumi/pkg/v3 v3.51.0/go.mod h1:bFQ7L/kRgR7NIcVM4ET0Jm7n0k2oCeiEIUQtcEibKLs=
-github.com/pulumi/pulumi/sdk/v3 v3.51.0 h1:i9xhvte67aNNk9q9M8/KV7An3zWp6Na8huKRznZx1lw=
-github.com/pulumi/pulumi/sdk/v3 v3.51.0/go.mod h1:tqQ4z9ocyM/UI2VQ7ZReWR3w6dF5ffEozoHipOMcDh4=
+github.com/pulumi/pulumi/pkg/v3 v3.53.1 h1:NSgzjci0ykEoKC2BHmp/brP7/V8ARafl8ovr76B9Jak=
+github.com/pulumi/pulumi/pkg/v3 v3.53.1/go.mod h1:XqciW5mPO8RxBEbN2/My9XjO829UQ2cHuhVLfoKM/yE=
+github.com/pulumi/pulumi/sdk/v3 v3.53.1 h1:fTYqe0fQiGshlOuHwpjOqQOb2SW3CSqXteeGcAuO+Bk=
+github.com/pulumi/pulumi/sdk/v3 v3.53.1/go.mod h1:IYcBrkAwKEGRVq7R1ne3XJKB5bcux5eL3M/zqco7d6Y=
 github.com/pulumi/schema-tools v0.1.0 h1:o1nVQaJEnmcA+3trxe+0sIDlrILxEIOvgUQ2Ze4OFsk=
 github.com/pulumi/schema-tools v0.1.0/go.mod h1:feL1siLWdcCNUm+irXoHyNHbGaqoX7pfYojpGZe2ziY=
 github.com/pulumi/terraform-diff-reader v0.0.0-20201211191010-ad4715e9285e h1:Dik4Qe/+xguB8JagPyXNlbOnRiXGmq/PSPQTGunYnTk=

sdk/dotnet/CloudTrail/GetServiceAccount.cs

@@ -36,7 +36,7 @@ public static class GetServiceAccount
         ///     var allowCloudtrailLogging = new Aws.S3.BucketPolicy("allowCloudtrailLogging", new()
         ///     {
         ///         Bucket = bucket.Id,
-        ///         Policy = Output.Tuple(main.Apply(getServiceAccountResult => getServiceAccountResult), main.Apply(getServiceAccountResult => getServiceAccountResult)).Apply(values =>
+        ///         Policy = Output.Tuple(main, main).Apply(values =>
         ///         {
         ///             var main = values.Item1;
         ///             var main1 = values.Item2;
@@ -100,7 +100,7 @@ public static Task<GetServiceAccountResult> InvokeAsync(GetServiceAccountArgs? a
         ///     var allowCloudtrailLogging = new Aws.S3.BucketPolicy("allowCloudtrailLogging", new()
         ///     {
         ///         Bucket = bucket.Id,
-        ///         Policy = Output.Tuple(main.Apply(getServiceAccountResult =&gt; getServiceAccountResult), main.Apply(getServiceAccountResult =&gt; getServiceAccountResult)).Apply(values =&gt;
+        ///         Policy = Output.Tuple(main, main).Apply(values =&gt;
         ///         {
         ///             var main = values.Item1;
         ///             var main1 = values.Item2;

sdk/dotnet/CloudTrail/Trail.cs

@@ -46,7 +46,7 @@ namespace Pulumi.Aws.CloudTrail
     ///     var fooBucketPolicy = new Aws.S3.BucketPolicy("fooBucketPolicy", new()
     ///     {
     ///         Bucket = fooBucketV2.Id,
-    ///         Policy = Output.Tuple(fooBucketV2.Arn, fooBucketV2.Arn, current.Apply(getCallerIdentityResult => getCallerIdentityResult)).Apply(values =>
+    ///         Policy = Output.Tuple(fooBucketV2.Arn, fooBucketV2.Arn, current).Apply(values =>
     ///         {
     ///             var fooBucketV2Arn = values.Item1;
     ///             var fooBucketV2Arn1 = values.Item2;
@@ -186,7 +186,7 @@ namespace Pulumi.Aws.CloudTrail
     ///                         Type = "AWS::S3::Object",
     ///                         Values = new[]
     ///                         {
-    ///                             important_bucket.Apply(getBucketResult => getBucketResult).Apply(important_bucket => $"{important_bucket.Apply(getBucketResult => getBucketResult.Arn)}/"),
+    ///                             important_bucket.Apply(important_bucket => $"{important_bucket.Apply(getBucketResult => getBucketResult.Arn)}/"),
     ///                         },
     ///                     },
     ///                 },

sdk/dotnet/CloudWatch/LogResourcePolicy.cs

@@ -55,7 +55,7 @@ namespace Pulumi.Aws.CloudWatch
     /// 
     ///     var elasticsearch_log_publishing_policyLogResourcePolicy = new Aws.CloudWatch.LogResourcePolicy("elasticsearch-log-publishing-policyLogResourcePolicy", new()
     ///     {
-    ///         PolicyDocument = elasticsearch_log_publishing_policyPolicyDocument.Apply(getPolicyDocumentResult => getPolicyDocumentResult).Apply(elasticsearch_log_publishing_policyPolicyDocument => elasticsearch_log_publishing_policyPolicyDocument.Apply(getPolicyDocumentResult => getPolicyDocumentResult.Json)),
+    ///         PolicyDocument = elasticsearch_log_publishing_policyPolicyDocument.Apply(elasticsearch_log_publishing_policyPolicyDocument => elasticsearch_log_publishing_policyPolicyDocument.Apply(getPolicyDocumentResult => getPolicyDocumentResult.Json)),
     ///         PolicyName = "elasticsearch-log-publishing-policy",
     ///     });
     /// 
@@ -102,7 +102,7 @@ namespace Pulumi.Aws.CloudWatch
     /// 
     ///     var route53_query_logging_policyLogResourcePolicy = new Aws.CloudWatch.LogResourcePolicy("route53-query-logging-policyLogResourcePolicy", new()
     ///     {
-    ///         PolicyDocument = route53_query_logging_policyPolicyDocument.Apply(getPolicyDocumentResult => getPolicyDocumentResult).Apply(route53_query_logging_policyPolicyDocument => route53_query_logging_policyPolicyDocument.Apply(getPolicyDocumentResult => getPolicyDocumentResult.Json)),
+    ///         PolicyDocument = route53_query_logging_policyPolicyDocument.Apply(route53_query_logging_policyPolicyDocument => route53_query_logging_policyPolicyDocument.Apply(getPolicyDocumentResult => getPolicyDocumentResult.Json)),
     ///         PolicyName = "route53-query-logging-policy",
     ///     });
     /// 

sdk/dotnet/CodeBuild/ResourcePolicy.cs

@@ -38,7 +38,7 @@ namespace Pulumi.Aws.CodeBuild
     ///     var exampleResourcePolicy = new Aws.CodeBuild.ResourcePolicy("exampleResourcePolicy", new()
     ///     {
     ///         ResourceArn = exampleReportGroup.Arn,
-    ///         Policy = Output.Tuple(currentPartition.Apply(getPartitionResult => getPartitionResult), currentCallerIdentity.Apply(getCallerIdentityResult => getCallerIdentityResult), exampleReportGroup.Arn).Apply(values =>
+    ///         Policy = Output.Tuple(currentPartition, currentCallerIdentity, exampleReportGroup.Arn).Apply(values =>
     ///         {
     ///             var currentPartition = values.Item1;
     ///             var currentCallerIdentity = values.Item2;

sdk/dotnet/Cognito/UserPoolClient.cs

@@ -90,7 +90,7 @@ namespace Pulumi.Aws.Cognito
     ///     var testRolePolicy = new Aws.Iam.RolePolicy("testRolePolicy", new()
     ///     {
     ///         Role = testRole.Id,
-    ///         Policy = Output.Tuple(current.Apply(getCallerIdentityResult => getCallerIdentityResult), testApp.ApplicationId).Apply(values =>
+    ///         Policy = Output.Tuple(current, testApp.ApplicationId).Apply(values =>
     ///         {
     ///             var current = values.Item1;
     ///             var applicationId = values.Item2;

sdk/dotnet/DirectoryService/LogService.cs

@@ -59,7 +59,7 @@ namespace Pulumi.Aws.DirectoryService
     /// 
     ///     var ad_log_policyLogResourcePolicy = new Aws.CloudWatch.LogResourcePolicy("ad-log-policyLogResourcePolicy", new()
     ///     {
-    ///         PolicyDocument = ad_log_policyPolicyDocument.Apply(getPolicyDocumentResult => getPolicyDocumentResult).Apply(ad_log_policyPolicyDocument => ad_log_policyPolicyDocument.Apply(getPolicyDocumentResult => getPolicyDocumentResult.Json)),
+    ///         PolicyDocument = ad_log_policyPolicyDocument.Apply(ad_log_policyPolicyDocument => ad_log_policyPolicyDocument.Apply(getPolicyDocumentResult => getPolicyDocumentResult.Json)),
     ///         PolicyName = "ad-log-policy",
     ///     });
     /// 

sdk/dotnet/Ec2/Inputs/NetworkInsightsAnalysisExplanationArgs.cs

@@ -139,6 +139,14 @@ public InputList<Inputs.NetworkInsightsAnalysisExplanationInternetGatewayArgs> I
         [Input("loadBalancerListenerPort")]
         public Input<int>? LoadBalancerListenerPort { get; set; }
 
+        [Input("loadBalancerTargetGroup")]
+        private InputList<Inputs.NetworkInsightsAnalysisExplanationLoadBalancerTargetGroupArgs>? _loadBalancerTargetGroup;
+        public InputList<Inputs.NetworkInsightsAnalysisExplanationLoadBalancerTargetGroupArgs> LoadBalancerTargetGroup
+        {
+            get => _loadBalancerTargetGroup ?? (_loadBalancerTargetGroup = new InputList<Inputs.NetworkInsightsAnalysisExplanationLoadBalancerTargetGroupArgs>());
+            set => _loadBalancerTargetGroup = value;
+        }
+
         [Input("loadBalancerTargetGroups")]
         private InputList<Inputs.NetworkInsightsAnalysisExplanationLoadBalancerTargetGroupArgs>? _loadBalancerTargetGroups;
         public InputList<Inputs.NetworkInsightsAnalysisExplanationLoadBalancerTargetGroupArgs> LoadBalancerTargetGroups
@@ -215,6 +223,14 @@ public InputList<Inputs.NetworkInsightsAnalysisExplanationRouteTableArgs> RouteT
             set => _routeTables = value;
         }
 
+        [Input("securityGroup")]
+        private InputList<Inputs.NetworkInsightsAnalysisExplanationSecurityGroupArgs>? _securityGroup;
+        public InputList<Inputs.NetworkInsightsAnalysisExplanationSecurityGroupArgs> SecurityGroup
+        {
+            get => _securityGroup ?? (_securityGroup = new InputList<Inputs.NetworkInsightsAnalysisExplanationSecurityGroupArgs>());
+            set => _securityGroup = value;
+        }
+
         [Input("securityGroupRules")]
         private InputList<Inputs.NetworkInsightsAnalysisExplanationSecurityGroupRuleArgs>? _securityGroupRules;
         public InputList<Inputs.NetworkInsightsAnalysisExplanationSecurityGroupRuleArgs> SecurityGroupRules

sdk/dotnet/Ec2/Inputs/NetworkInsightsAnalysisExplanationGetArgs.cs

@@ -139,6 +139,14 @@ public InputList<Inputs.NetworkInsightsAnalysisExplanationInternetGatewayGetArgs
         [Input("loadBalancerListenerPort")]
         public Input<int>? LoadBalancerListenerPort { get; set; }
 
+        [Input("loadBalancerTargetGroup")]
+        private InputList<Inputs.NetworkInsightsAnalysisExplanationLoadBalancerTargetGroupGetArgs>? _loadBalancerTargetGroup;
+        public InputList<Inputs.NetworkInsightsAnalysisExplanationLoadBalancerTargetGroupGetArgs> LoadBalancerTargetGroup
+        {
+            get => _loadBalancerTargetGroup ?? (_loadBalancerTargetGroup = new InputList<Inputs.NetworkInsightsAnalysisExplanationLoadBalancerTargetGroupGetArgs>());
+            set => _loadBalancerTargetGroup = value;
+        }
+
         [Input("loadBalancerTargetGroups")]
         private InputList<Inputs.NetworkInsightsAnalysisExplanationLoadBalancerTargetGroupGetArgs>? _loadBalancerTargetGroups;
         public InputList<Inputs.NetworkInsightsAnalysisExplanationLoadBalancerTargetGroupGetArgs> LoadBalancerTargetGroups
@@ -215,6 +223,14 @@ public InputList<Inputs.NetworkInsightsAnalysisExplanationRouteTableGetArgs> Rou
             set => _routeTables = value;
         }
 
+        [Input("securityGroup")]
+        private InputList<Inputs.NetworkInsightsAnalysisExplanationSecurityGroupGetArgs>? _securityGroup;
+        public InputList<Inputs.NetworkInsightsAnalysisExplanationSecurityGroupGetArgs> SecurityGroup
+        {
+            get => _securityGroup ?? (_securityGroup = new InputList<Inputs.NetworkInsightsAnalysisExplanationSecurityGroupGetArgs>());
+            set => _securityGroup = value;
+        }
+
         [Input("securityGroupRules")]
         private InputList<Inputs.NetworkInsightsAnalysisExplanationSecurityGroupRuleGetArgs>? _securityGroupRules;
         public InputList<Inputs.NetworkInsightsAnalysisExplanationSecurityGroupRuleGetArgs> SecurityGroupRules

sdk/dotnet/Ec2/Outputs/GetNetworkInsightsAnalysisExplanationResult.cs

@@ -32,6 +32,7 @@ public sealed class GetNetworkInsightsAnalysisExplanationResult
         public readonly ImmutableArray<Outputs.GetNetworkInsightsAnalysisExplanationInternetGatewayResult> InternetGateways;
         public readonly string LoadBalancerArn;
         public readonly int LoadBalancerListenerPort;
+        public readonly ImmutableArray<Outputs.GetNetworkInsightsAnalysisExplanationLoadBalancerTargetGroupResult> LoadBalancerTargetGroup;
         public readonly ImmutableArray<Outputs.GetNetworkInsightsAnalysisExplanationLoadBalancerTargetGroupResult> LoadBalancerTargetGroups;
         public readonly int LoadBalancerTargetPort;
         public readonly string MissingComponent;
@@ -44,6 +45,7 @@ public sealed class GetNetworkInsightsAnalysisExplanationResult
         public readonly ImmutableArray<string> Protocols;
         public readonly ImmutableArray<Outputs.GetNetworkInsightsAnalysisExplanationRouteTableRouteResult> RouteTableRoutes;
         public readonly ImmutableArray<Outputs.GetNetworkInsightsAnalysisExplanationRouteTableResult> RouteTables;
+        public readonly ImmutableArray<Outputs.GetNetworkInsightsAnalysisExplanationSecurityGroupResult> SecurityGroup;
         public readonly ImmutableArray<Outputs.GetNetworkInsightsAnalysisExplanationSecurityGroupRuleResult> SecurityGroupRules;
         public readonly ImmutableArray<Outputs.GetNetworkInsightsAnalysisExplanationSecurityGroupResult> SecurityGroups;
         public readonly ImmutableArray<Outputs.GetNetworkInsightsAnalysisExplanationSourceVpcResult> SourceVpcs;
@@ -100,6 +102,8 @@ public sealed class GetNetworkInsightsAnalysisExplanationResult
 
             int loadBalancerListenerPort,
 
+            ImmutableArray<Outputs.GetNetworkInsightsAnalysisExplanationLoadBalancerTargetGroupResult> loadBalancerTargetGroup,
+
             ImmutableArray<Outputs.GetNetworkInsightsAnalysisExplanationLoadBalancerTargetGroupResult> loadBalancerTargetGroups,
 
             int loadBalancerTargetPort,
@@ -124,6 +128,8 @@ public sealed class GetNetworkInsightsAnalysisExplanationResult
 
             ImmutableArray<Outputs.GetNetworkInsightsAnalysisExplanationRouteTableResult> routeTables,
 
+            ImmutableArray<Outputs.GetNetworkInsightsAnalysisExplanationSecurityGroupResult> securityGroup,
+
             ImmutableArray<Outputs.GetNetworkInsightsAnalysisExplanationSecurityGroupRuleResult> securityGroupRules,
 
             ImmutableArray<Outputs.GetNetworkInsightsAnalysisExplanationSecurityGroupResult> securityGroups,
@@ -173,6 +179,7 @@ public sealed class GetNetworkInsightsAnalysisExplanationResult
             InternetGateways = internetGateways;
             LoadBalancerArn = loadBalancerArn;
             LoadBalancerListenerPort = loadBalancerListenerPort;
+            LoadBalancerTargetGroup = loadBalancerTargetGroup;
             LoadBalancerTargetGroups = loadBalancerTargetGroups;
             LoadBalancerTargetPort = loadBalancerTargetPort;
             MissingComponent = missingComponent;
@@ -185,6 +192,7 @@ public sealed class GetNetworkInsightsAnalysisExplanationResult
             Protocols = protocols;
             RouteTableRoutes = routeTableRoutes;
             RouteTables = routeTables;
+            SecurityGroup = securityGroup;
             SecurityGroupRules = securityGroupRules;
             SecurityGroups = securityGroups;
             SourceVpcs = sourceVpcs;

sdk/dotnet/Ec2/Outputs/NetworkInsightsAnalysisExplanation.cs

@@ -32,6 +32,7 @@ public sealed class NetworkInsightsAnalysisExplanation
         public readonly ImmutableArray<Outputs.NetworkInsightsAnalysisExplanationInternetGateway> InternetGateways;
         public readonly string? LoadBalancerArn;
         public readonly int? LoadBalancerListenerPort;
+        public readonly ImmutableArray<Outputs.NetworkInsightsAnalysisExplanationLoadBalancerTargetGroup> LoadBalancerTargetGroup;
         public readonly ImmutableArray<Outputs.NetworkInsightsAnalysisExplanationLoadBalancerTargetGroup> LoadBalancerTargetGroups;
         public readonly int? LoadBalancerTargetPort;
         public readonly string? MissingComponent;
@@ -44,6 +45,7 @@ public sealed class NetworkInsightsAnalysisExplanation
         public readonly ImmutableArray<string> Protocols;
         public readonly ImmutableArray<Outputs.NetworkInsightsAnalysisExplanationRouteTableRoute> RouteTableRoutes;
         public readonly ImmutableArray<Outputs.NetworkInsightsAnalysisExplanationRouteTable> RouteTables;
+        public readonly ImmutableArray<Outputs.NetworkInsightsAnalysisExplanationSecurityGroup> SecurityGroup;
         public readonly ImmutableArray<Outputs.NetworkInsightsAnalysisExplanationSecurityGroupRule> SecurityGroupRules;
         public readonly ImmutableArray<Outputs.NetworkInsightsAnalysisExplanationSecurityGroup> SecurityGroups;
         public readonly ImmutableArray<Outputs.NetworkInsightsAnalysisExplanationSourceVpc> SourceVpcs;
@@ -100,6 +102,8 @@ public sealed class NetworkInsightsAnalysisExplanation
 
             int? loadBalancerListenerPort,
 
+            ImmutableArray<Outputs.NetworkInsightsAnalysisExplanationLoadBalancerTargetGroup> loadBalancerTargetGroup,
+
             ImmutableArray<Outputs.NetworkInsightsAnalysisExplanationLoadBalancerTargetGroup> loadBalancerTargetGroups,
 
             int? loadBalancerTargetPort,
@@ -124,6 +128,8 @@ public sealed class NetworkInsightsAnalysisExplanation
 
             ImmutableArray<Outputs.NetworkInsightsAnalysisExplanationRouteTable> routeTables,
 
+            ImmutableArray<Outputs.NetworkInsightsAnalysisExplanationSecurityGroup> securityGroup,
+
             ImmutableArray<Outputs.NetworkInsightsAnalysisExplanationSecurityGroupRule> securityGroupRules,
 
             ImmutableArray<Outputs.NetworkInsightsAnalysisExplanationSecurityGroup> securityGroups,
@@ -173,6 +179,7 @@ public sealed class NetworkInsightsAnalysisExplanation
             InternetGateways = internetGateways;
             LoadBalancerArn = loadBalancerArn;
             LoadBalancerListenerPort = loadBalancerListenerPort;
+            LoadBalancerTargetGroup = loadBalancerTargetGroup;
             LoadBalancerTargetGroups = loadBalancerTargetGroups;
             LoadBalancerTargetPort = loadBalancerTargetPort;
             MissingComponent = missingComponent;
@@ -185,6 +192,7 @@ public sealed class NetworkInsightsAnalysisExplanation
             Protocols = protocols;
             RouteTableRoutes = routeTableRoutes;
             RouteTables = routeTables;
+            SecurityGroup = securityGroup;
             SecurityGroupRules = securityGroupRules;
             SecurityGroups = securityGroups;
             SourceVpcs = sourceVpcs;

sdk/dotnet/Ecr/RegistryPolicy.cs

@@ -30,7 +30,7 @@ namespace Pulumi.Aws.Ecr
     /// 
     ///     var example = new Aws.Ecr.RegistryPolicy("example", new()
     ///     {
-    ///         Policy = Output.Tuple(currentPartition.Apply(getPartitionResult => getPartitionResult), currentCallerIdentity.Apply(getCallerIdentityResult => getCallerIdentityResult), currentPartition.Apply(getPartitionResult => getPartitionResult), currentRegion.Apply(getRegionResult => getRegionResult), currentCallerIdentity.Apply(getCallerIdentityResult => getCallerIdentityResult)).Apply(values =>
+    ///         Policy = Output.Tuple(currentPartition, currentCallerIdentity, currentPartition, currentRegion, currentCallerIdentity).Apply(values =>
     ///         {
     ///             var currentPartition = values.Item1;
     ///             var currentCallerIdentity = values.Item2;