Method execute_graph_path

nodedb/src/data/executor/handlers/graph_traversal.rs:14–58

(
        &self,
        task: &ExecutionTask,
        tid: u64,
        src: &str,
        dst: &str,
        edge_label: &Option<String>,
        max_depth: usize,
        frontier_bitmap: Option<&n

impl CoreLoop {
    #[allow(clippy::too_many_arguments)]
    pub(in crate::data::executor) fn execute_graph_path(
        &self,
        task: &ExecutionTask,
        tid: u64,
        src: &str,
        dst: &str,
        edge_label: &Option<String>,
        max_depth: usize,
        frontier_bitmap: Option<&nodedb_types::SurrogateBitmap>,
    ) -> Response {
        let max_depth =
            max_depth.min(crate::engine::graph::traversal_options::MAX_GRAPH_TRAVERSAL_DEPTH);
        debug!(core = self.core_id, tid, %src, %dst, ?edge_label, max_depth, "graph path");
        let path = match self.csr_partition(tid) {
            Some(partition) => partition.shortest_path(
                src,
                dst,
                edge_label.as_deref(),
                max_depth,
                self.graph_tuning.max_visited,
                frontier_bitmap,
            ),
            None => None,
        };
        match path {
            Some(path) => {
                if let Some(ref m) = self.metrics {
                    m.record_graph_traversal();
                }
                match crate::data::executor::response_codec::encode(&path) {
                    Ok(payload) => self.response_with_payload(task, payload),
                    Err(e) => {
                        warn!(core = self.core_id, layer = DiagnosticLayer::WireShape.as_str(), error = %e, "graph path serialization failed");
                        self.response_error(
                            task,
                            ErrorCode::Internal {
                                detail: e.to_string(),
                            },
                        )
                    }
                }
            }
            None => self.response_error(task, ErrorCode::NotFound),
        }
    }

    pub(in crate::data::executor) fn execute_graph_subgraph(
        &self,