Add 'partition_by_time_column' property to the IncrementalByTimeRange model kind (default: True to keep the original behaviour)
def
migrate_schemas(engine_adapter, schema, **kwargs):
def
migrate_rows(engine_adapter, schema, **kwargs):