Is it just me or is this wrong?

generic_type = type(sql_types[0].as_generic())
        if isinstance(generic_type, type):

That's from SQLConnector.merge_sql_types (streams/sql.py in the SDK). I think maybe that wants to be

isinstance(generic_type, sql_types[1])

? 🤔