def validate_experiment_message_id()

in scripts/validate.py [0:0]

• 16 lines of code
• 3 McCabe index (conditional complexity)

def validate_experiment_message_id(exp_slug, branch):
    """This validation enforces certain naming convention for some message
    types such as CFR in order to support the automated analysis feature of
    Jetstream.
    """
    message_type, branch_message = get_branch_message(branch)
    if branch_message is None:
        return

    if message_type == "cfr":
        print(f"\tValidate experiment message ID for branch {branch['slug']}")

        assert branch_message["id"] == f"{exp_slug}:{branch['slug']}", (
            f"Invalid CFR message ID {branch_message['id']}, "
            f"it should be named as {{experiment-slug}}:{{branch-slug}}"
        )
        assert (
            branch_message["content"]["bucket_id"] == f"{exp_slug}:{branch['slug']}"
        ), (
            f"Invalid CFR bucket_id {branch_message['content']['bucket_id']}, "
            f"it should be named as {{experiment-slug}}:{{branch-slug}}"
        )