         :status-check-loop (thread (status-check-loop status-check-ch ack-ch reset-payload-node-ch))
         :ack-loop (thread (ack-loop ack-ch commit-tx-ch))
         :commit-tx-loop (thread (commit-tx-loop commit-tx-ch close-resources-ch))
-        :close-resources-loop (thread (close-resources-loop close-resources-ch complete-task-ch))
-        :complete-task-loop (thread (complete-task-loop complete-task-ch reset-payload-node-ch))
-        :reset-payload-node (thread (reset-payload-node reset-payload-node-ch)))))
+        :close-resources-loop (thread (close-resources-loop close-resources-ch reset-payload-node-ch))
+        :reset-payload-node (thread (reset-payload-node reset-payload-node-ch complete-task-ch))
+        :complete-task-loop (thread (complete-task-loop complete-task-ch)))))
 
   (stop [component]
     (prn "Stopping Task Pipeline")

        java.lang.Exception
        (fn [e & _] (.printStackTrace e)))

      (dire/with-handler! #'complete-task-loop
        java.lang.Exception
        (fn [e & _] (.printStackTrace e)))

      (dire/with-handler! #'reset-payload-node
        java.lang.Exception
        (fn [e & _] (.printStackTrace e)))


          ack-ch (chan 1)
          commit-tx-ch (chan 1)
          close-resources-ch (chan 1)
          reset-payload-node-ch (chan 1)
          complete-task-ch (chan 1)

          pipeline-data {:ingress-queues (:task/ingress-queues (:task payload))
                         :egress-queues (:task/egress-queues (:task payload))
