def METHOD_NAME(self) -> None:
    """Test that workers can start if the DB is a newer schema version"""
    db_pool = self.hs.get_datastores().main.db_pool
    db_conn = LoggingDatabaseConnection(
        db_pool._db_pool.connect(),
        db_pool.engine,
        "tests",
    )
    cur = db_conn.cursor()
    cur.execute("UPDATE schema_version SET version = ?", (SCHEMA_VERSION + 1,))
    db_conn.commit()
    prepare_database(db_conn, db_pool.engine, self.hs.config)