in sagemaker_studio_sparkmagic_lib/emr.py [0:0]
def __init__(self, cluster_id=None, role_arn=None, emr=None):
if not emr:
sess = self._get_boto3_session(role_arn)
emr = sess.client(
"emr", endpoint_url=utils.get_emr_endpoint_url(self._get_region())
)
self._get_cluster(emr, cluster_id)
self._get_instances(emr, cluster_id)
self._get_security_conf(emr)
logger.info(f"Successfully read emr cluster({cluster_id}) details")