def to_state_json()

in aws_emr_launch/constructs/step_functions/emr_tasks.py [0:0]

• 64 lines of code
• 1 McCabe index (conditional complexity)

    def to_state_json(self) -> Mapping[Any, Any]:
        task = {
            "Resource": self.get_resource_arn("elasticmapreduce", "createCluster", self._integration_pattern),
            "Parameters": sfn.FieldUtils.render_object(
                {
                    "AdditionalInfo": sfn.TaskInput.from_data_at("$.AdditionalInfo").value,
                    "AmiVersion": sfn.TaskInput.from_data_at("$.AmiVersion").value,
                    "Applications": sfn.TaskInput.from_data_at("$.Applications").value,
                    "AutoScalingRole": sfn.TaskInput.from_data_at("$.AutoScalingRole").value,
                    "BootstrapActions": sfn.TaskInput.from_data_at("$.BootstrapActions").value,
                    "Configurations": sfn.TaskInput.from_data_at("$.Configurations").value,
                    "CustomAmiId": sfn.TaskInput.from_data_at("$.CustomAmiId").value,
                    "EbsRootVolumeSize": sfn.TaskInput.from_data_at("$.EbsRootVolumeSize").value,
                    "Instances": {
                        "AdditionalMasterSecurityGroups": sfn.TaskInput.from_data_at(
                            "$.Instances.AdditionalMasterSecurityGroups"
                        ).value,
                        "AdditionalSlaveSecurityGroups": sfn.TaskInput.from_data_at(
                            "$.Instances.AdditionalSlaveSecurityGroups"
                        ).value,
                        "Ec2KeyName": sfn.TaskInput.from_data_at("$.Instances.Ec2KeyName").value,
                        "Ec2SubnetId": sfn.TaskInput.from_data_at("$.Instances.Ec2SubnetId").value,
                        "Ec2SubnetIds": sfn.TaskInput.from_data_at("$.Instances.Ec2SubnetIds").value,
                        "EmrManagedMasterSecurityGroup": sfn.TaskInput.from_data_at(
                            "$.Instances.EmrManagedMasterSecurityGroup"
                        ).value,
                        "EmrManagedSlaveSecurityGroup": sfn.TaskInput.from_data_at(
                            "$.Instances.EmrManagedSlaveSecurityGroup"
                        ).value,
                        "HadoopVersion": sfn.TaskInput.from_data_at("$.Instances.HadoopVersion").value,
                        "InstanceCount": sfn.TaskInput.from_data_at("$.Instances.InstanceCount").value,
                        "InstanceFleets": sfn.TaskInput.from_data_at("$.Instances.InstanceFleets").value,
                        "InstanceGroups": sfn.TaskInput.from_data_at("$.Instances.InstanceGroups").value,
                        "KeepJobFlowAliveWhenNoSteps": True,
                        "MasterInstanceType": sfn.TaskInput.from_data_at("$.Instances.MasterInstanceType").value,
                        "Placement": sfn.TaskInput.from_data_at("$.Instances.Placement").value,
                        "ServiceAccessSecurityGroup": sfn.TaskInput.from_data_at(
                            "$.Instances.ServiceAccessSecurityGroup"
                        ).value,
                        "SlaveInstanceType": sfn.TaskInput.from_data_at("$.Instances.SlaveInstanceType").value,
                        "TerminationProtected": sfn.TaskInput.from_data_at("$.Instances.TerminationProtected").value,
                    },
                    "JobFlowRole": sfn.TaskInput.from_data_at("$.JobFlowRole").value,
                    "KerberosAttributes": sfn.TaskInput.from_data_at("$.KerberosAttributes").value,
                    "LogUri": sfn.TaskInput.from_data_at("$.LogUri").value,
                    "ManagedScalingPolicy": sfn.TaskInput.from_data_at("$.ManagedScalingPolicy").value,
                    "Name": sfn.TaskInput.from_data_at("$.Name").value,
                    "NewSupportedProducts": sfn.TaskInput.from_data_at("$.NewSupportedProducts").value,
                    "ReleaseLabel": sfn.TaskInput.from_data_at("$.ReleaseLabel").value,
                    "RepoUpgradeOnBoot": sfn.TaskInput.from_data_at("$.RepoUpgradeOnBoot").value,
                    "ScaleDownBehavior": sfn.TaskInput.from_data_at("$.ScaleDownBehavior").value,
                    "SecurityConfiguration": sfn.TaskInput.from_data_at("$.SecurityConfiguration").value,
                    "ServiceRole": sfn.TaskInput.from_data_at("$.ServiceRole").value,
                    "StepConcurrencyLevel": sfn.TaskInput.from_data_at("$.StepConcurrencyLevel").value,
                    "SupportedProducts": sfn.TaskInput.from_data_at("$.SupportedProducts").value,
                    "Tags": sfn.TaskInput.from_data_at("$.Tags").value,
                    "VisibleToAllUsers": sfn.TaskInput.from_data_at("$.VisibleToAllUsers").value,
                }
            ),
        }
        task.update(self._render_next_end())
        task.update(self._render_retry_catch())
        task.update(self._render_task_base())
        return task