def METHOD_NAME():
    events = connect_to().logs.filter_log_events(
        logGroupName=f"/aws/lambda/{collect_fn_name}"
    )["events"]
    message_events = [e["message"] for e in events if msg in e["message"]]
    return len(message_events) >= 2