def create()

in src/functions/rds/cluster.py [0:0]


def create(event, context):
    logger.info("Got Create")
    properties = event.get("ResourceProperties", {})
    db_cluster_identifier = properties.get("DBClusterIdentifier")

    db_cluster_resource_id = _rds_describe_db_clusters(db_cluster_identifier)

    helper.Data.update({"DbClusterResourceId": db_cluster_resource_id})

    return helper.PhysicalResourceId