File tree Expand file tree Collapse file tree 1 file changed +0
-9
lines changed Expand file tree Collapse file tree 1 file changed +0
-9
lines changed Original file line number Diff line number Diff line change @@ -72,10 +72,6 @@ async fn main() -> Result<(), ServiceError> {
7272
7373 let mut offset = Some ( start_offset) ;
7474
75- let dataset_id = std:: env:: var ( "dataset_id" )
76- . map ( |dataset_str| uuid:: Uuid :: parse_str ( & dataset_str) . ok ( ) . unwrap ( ) )
77- . unwrap_or ( uuid:: Uuid :: max ( ) ) ;
78-
7975 while let Some ( cur_offset) = offset {
8076 use trieve_server:: data:: schema:: chunk_group_bookmarks:: dsl as chunk_group_bookmarks_columns;
8177 use trieve_server:: data:: schema:: chunk_metadata:: dsl as chunk_metadata_columns;
@@ -85,16 +81,11 @@ async fn main() -> Result<(), ServiceError> {
8581 ServiceError :: BadRequest ( "Could not get database connection" . to_string ( ) )
8682 } ) ?;
8783
88- println ! ( "Fetching from postgres @ {}" , cur_offset) ;
89-
90- // Get postgres_fetch_points_count chunk_metadata
9184 let qdrant_dataset_id_pairs = chunk_metadata_columns:: chunk_metadata
9285 . select ( (
9386 chunk_metadata_columns:: id,
9487 chunk_metadata_columns:: qdrant_point_id,
95- chunk_metadata_columns:: dataset_id,
9688 ) )
97- . filter ( chunk_metadata_columns:: dataset_id. eq ( dataset_id) )
9889 . filter ( chunk_metadata_columns:: id. ge ( cur_offset) )
9990 . order_by ( chunk_metadata_columns:: id)
10091 . limit ( postgres_fetch_points_count)
You can’t perform that action at this time.
0 commit comments