Use sparse sidecar for unweighted shortest path

Author: shisoft

src/dsl/graph/exec_path.rs

@@ -7,6 +7,7 @@ use neb::dovahkiin::expr::serde::Expr;
 use neb::ram::types::Id;
 
 use crate::dsl::exec_helpers::distributed_directions_for_edge_schemas;
+use crate::dsl::graph::exec_path_sparse::try_execute_sparse_sidecar_shortest_path;
 use crate::dsl::graph::json::{PathsResult, ShortestPathResult};
 use crate::dsl::graph::path_materialize::{
     build_path_edges, fetch_vertices, materialize_expand_edges,
@@ -188,23 +189,30 @@ pub async fn execute_path(
             )
             .await?
         } else {
-            info!(
-                "dsl path executor: unweighted path using gas_bidirectional_bfs_with_parent (all_candidates={})",
-                query.all_candidates
-            );
-            gas_bidirectional_bfs_with_parent(
-                &runtime.compute_coordinator(),
-                runtime.server_id(),
-                &from_ids,
-                &to_ids,
-                &query.edge_schema_ids,
-                &direction_variants,
-                query.max_depth as u32,
-                query.max_visited,
-                query.vertex_filter.clone(),
-                query.edge_filter.clone(),
-            )
-            .await?
+            match try_execute_sparse_sidecar_shortest_path(runtime, &query, &from_ids, &to_ids)
+                .await?
+            {
+                Some(result) => result,
+                None => {
+                    info!(
+                        "dsl path executor: unweighted path using gas_bidirectional_bfs_with_parent (all_candidates={})",
+                        query.all_candidates
+                    );
+                    gas_bidirectional_bfs_with_parent(
+                        &runtime.compute_coordinator(),
+                        runtime.server_id(),
+                        &from_ids,
+                        &to_ids,
+                        &query.edge_schema_ids,
+                        &direction_variants,
+                        query.max_depth as u32,
+                        query.max_visited,
+                        query.vertex_filter.clone(),
+                        query.edge_filter.clone(),
+                    )
+                    .await?
+                }
+            }
         }
     };