def kafka_get_arn()

in helpers/functions.py [0:0]

• 10 lines of code
• 4 McCabe index (conditional complexity)

def kafka_get_arn() -> str:
    """ get the arn for the kakfa cluster startingwith elkk- """
    kafka_clusters = kafkaclient.list_clusters()
    try:
        return [
            clstr["ClusterArn"]
            for clstr in kafka_clusters["ClusterInfoList"]
            if clstr["Tags"]["project"] == constants["PROJECT_TAG"]
        ][0]
    except IndexError:
        return ""