def METHOD_NAME() -> None:
    from augur.tasks.init.celery_app import engine
    logger = logging.getLogger(METHOD_NAME.__name__)
    tool_source = 'Contributor Breadth Worker'
    tool_version = '0.0.1'
    data_source = 'GitHub API'
    # This version of the query pulls contributors who have not had any data collected yet
    # To the top of the list
    cntrb_login_query = s.sql.text("""
            SELECT DISTINCT
                gh_login,
                cntrb_id 
            FROM
                (
                SELECT DISTINCT
                    gh_login,
                    cntrb_id,
                    data_collection_date 
                FROM
                    (
                    SELECT DISTINCT
                        contributors.gh_login,
                        contributors.cntrb_id,
                        contributor_repo.data_collection_date :: DATE 
                    FROM
                        contributor_repo
                        RIGHT OUTER JOIN contributors ON contributors.cntrb_id = contributor_repo.cntrb_id 
                        AND contributors.gh_login IS NOT NULL 
                    ORDER BY
                        contributor_repo.data_collection_date :: DATE NULLS FIRST 
                    ) A 
                ORDER BY
                data_collection_date DESC NULLS FIRST 
                ) b
    """)
    result = engine.execute(cntrb_login_query)
    current_cntrb_logins = [dict(row) for row in result]
    cntrb_newest_events_query = s.sql.text("""
        SELECT c.gh_login, MAX(cr.created_at) as newest_event_date
        FROM contributor_repo AS cr
        JOIN contributors AS c ON cr.cntrb_id = c.cntrb_id
        GROUP BY c.gh_login;
    """)
    cntrb_newest_events_list = engine.execute(cntrb_newest_events_query)
    cntrb_newest_events_list = [dict(row) for row in cntrb_newest_events_list]
    cntrb_newest_events_map = {}
    for cntrb_event in cntrb_newest_events_list:
        gh_login = cntrb_event["gh_login"]
        newest_event_date = cntrb_event["newest_event_date"]
        cntrb_newest_events_map[gh_login] = newest_event_date
    with GithubTaskManifest(logger) as manifest:
        index = 1
        total = len(current_cntrb_logins)
        for cntrb in current_cntrb_logins:
            print(f"Processing cntrb {index} of {total}")
            index += 1
            repo_cntrb_url = f"https://api.github.com/users/{cntrb['gh_login']}/events"
            newest_event_in_db = datetime(1970, 1, 1)
            if cntrb["gh_login"] in cntrb_newest_events_map:
                newest_event_in_db = cntrb_newest_events_map[cntrb["gh_login"]]
            cntrb_events = []
            for page_data, page in GithubPaginator(repo_cntrb_url, manifest.key_auth, logger).iter_pages():
                if page_data: 
                    cntrb_events += page_data
                    oldest_event_on_page = datetime.strptime(page_data[-1]["created_at"], "%Y-%m-%dT%H:%M:%SZ")
                    if oldest_event_on_page < newest_event_in_db:
                        print("Found cntrb events we already have...skipping the rest")
                        break
            if len(cntrb_events) == 0:
                logger.info("There are no cntrb events, or new events for this user.\n")
                continue
            events = process_contributor_events(cntrb, cntrb_events, logger, tool_source, tool_version, data_source)
            logger.info(f"Inserting {len(events)} events")
            natural_keys = ["event_id", "tool_version"]
            manifest.augur_db.insert_data(events, ContributorRepo, natural_keys)  