             [clojure.core.async :as a]
             [neb.core :as neb]
             [cluster-connector.utils.for-debug :refer [$ spy]]
-            [morpheus.models.edge.base :as eb])
+            [morpheus.models.edge.base :as eb]
+            [morpheus.query.lang.AST :as AST])
   (:import (java.util.concurrent TimeoutException)))
 
 ;; Distributed deepeth first search divised by S.A.M. Makki and George Havas

(defn proc-forward-msg [task-id data]
  (let [[vertex-id stack] data
        {:keys [filters max-deepth stop-cond path-only? tail-only?]} (compute/get-task task-id)
        neighbours (apply edges/neighbours-edges (vertex/get-veterx-by-id vertex-id) (if filters (mapcat identity filters) []))
        current-vertex-stat (atom nil)
        proced-stack (doall (map (fn [v]
                                   (let [[svid] v]

                                           )
                                       v)))
                                 stack))
        proced-stack (if vertex-vailed
                       proced-stack
                       (filter (fn [[svid]] (not= svid vertex-id)) proced-stack))
        deepth (@current-vertex-stat 2)
        next-depth (inc deepth)
        stack-verteics (set (map first stack))
