def load_dialect_impl(self, dialect):
if dialect.name == 'postgresql':
from sqlalchemy.dialects.postgresql import JSONB
return dialect.type_descriptor(JSONB())
else:
return dialect.type_descriptor(VARCHAR())