fix integration tests

Author: themisvaltinos

sqlmesh/core/engine_adapter/base.py

@@ -1756,7 +1756,17 @@ def remove_managed_columns(
                     "static",
                     existing_rows_query.where(valid_to_col.is_(exp.Null()).not_())
                     if truncate
-                    else existing_rows_query.where(
+                    else exp.select(
+                        *(
+                            exp.cast(valid_to_col, time_data_type).as_(col)
+                            if col == valid_to_col.name
+                            else exp.column(col)
+                            for col in columns_to_types
+                        ),
+                        exp.true().as_("_exists"),
+                    )
+                    .from_(target_table)
+                    .where(
                         exp.and_(
                             valid_from_col <= cleanup_ts,
                             exp.and_(