fix condition test

Author: themisvaltinos

sqlmesh/core/engine_adapter/base.py

@@ -1717,14 +1717,14 @@ def remove_managed_columns(
             cleanup_ts = to_time_column(start, time_data_type, self.dialect, nullable=True)
 
             # Delete records that were created at or after cleanup point
-            self.delete_from(table_name=target_table, where=valid_from_col >= cleanup_ts)
+            self.delete_from(table_name=target_table, where=valid_from_col > cleanup_ts)
 
             # "Re-open" records that were closed at or after cleanup point
             self.update_table(
                 table_name=target_table,
                 properties={valid_to_col.name: exp.Null()},
                 where=exp.and_(
-                    valid_to_col >= cleanup_ts,
+                    valid_to_col > cleanup_ts,
                 ),
             )
 

tests/core/test_integration.py

@@ -6612,7 +6612,7 @@ def test_scd_type_2_restatement(init_and_plan_context: t.Callable):
             "prod",
             skip_tests=True,
             restate_models=["memory.hr_system.employee_history"],
-            start="2023-01-08 15:11:00",
+            start="2023-01-08 15:09:00",
         ).build()
         context.apply(plan)
         restated_data = context.engine_adapter.fetchdf(query)