in aws_emr_launch/constructs/step_functions/emr_launch_function.py [0:0]
def to_json(self) -> Dict[str, Any]:
return {
"LaunchFunctionName": self._launch_function_name,
"Namespace": self._namespace,
"EMRProfile": f"{self._emr_profile.namespace}/{self._emr_profile.profile_name}",
"ClusterConfiguration": (
f"{self._cluster_configuration.namespace}/{self._cluster_configuration.configuration_name}"
),
"ClusterName": self._cluster_name,
"DefaultFailIfClusterRunning": self._default_fail_if_cluster_running,
"SuccessTopic": self._success_topic.topic_arn if self._success_topic is not None else None,
"FailureTopic": self._failure_topic.topic_arn if self._failure_topic is not None else None,
"OverrideClusterConfigsLambda": self._override_cluster_configs_lambda.function_arn
if self._override_cluster_configs_lambda is not None
else None,
"AllowedClusterConfigOverrides": self._allowed_cluster_config_overrides,
"StateMachine": self._state_machine.state_machine_arn,
"Description": self._description,
"ClusterTags": [{"Key": t.key, "Value": t.value} for t in self._cluster_tags],
"WaitForClusterStart": self._wait_for_cluster_start,
}