         (tap (:ack-mult coordinator) ack-ch-spy)
         (tap (:offer-mult coordinator) offer-ch-spy)
 
-        (extensions/write-place sync peer-node-a payload-node-a)
-        (extensions/on-change sync payload-node-a #(>!! sync-spy-a %))
+        (extensions/write-place sync peer-node-a payload-node-a-1)
+        (extensions/on-change sync payload-node-a-1 #(>!! sync-spy-a %))
 
-        (extensions/write-place sync peer-node-b payload-node-b)
-        (extensions/on-change sync payload-node-b #(>!! sync-spy-b %))
+        (extensions/write-place sync peer-node-b payload-node-b-1)
+        (extensions/on-change sync payload-node-b-1 #(>!! sync-spy-b %))
 
         (>!! (:born-peer-ch-head coordinator) peer-node-a)
         (>!! (:born-peer-ch-head coordinator) peer-node-b)


        (>!! (:planning-ch-head coordinator) {:catalog catalog :workflow workflow})

        (<!! sync-spy-a)
        (<!! sync-spy-b)

        (testing "Both payloads are received"
          (let [payload-a (extensions/read-place sync payload-node-a)
                payload-b (extensions/read-place sync payload-node-b)]
            (is (not (nil? payload-a)))
            (is (not (nil? payload-b)))
            (is (not= payload-a payload-b))

            (<!! status-spy)
            (<!! status-spy)

            (extensions/write-place sync peer-node-a payload-node-a-2)
            (extensions/on-change sync payload-node-a-2 #(>!! sync-spy-a %))

            (extensions/write-place sync peer-node-b payload-node-b-2)
            (extensions/on-change sync payload-node-b-2 #(>!! sync-spy-b %))

            (extensions/touch-place sync (:completion (:nodes payload-a)))
            (extensions/touch-place sync (:completion (:nodes payload-b)))

            (<!! offer-ch-spy)
            (<!! offer-ch-spy)

            (let [[v ch] (alts!! [sync-spy-a sync-spy-b])
                  nodes (:nodes (extensions/read-place sync (:path v)))]
              (extensions/on-change sync (:status nodes) #(>!! status-spy %))
              (extensions/touch-place sync (:ack nodes))

              (<!! ack-ch-spy)
              (<!! status-spy)

              (extensions/touch-place sync (:completion nodes))
              (<!! offer-ch-spy))

            (testing "All tasks are complete"
              (let [db (d/db (:conn log))
                    query '[:find (count ?task) :where
                            [?task :task/complete? true]]
                    result (ffirst (d/q query db))]
                (is (= result 3))))))))
    
    {:eviction-delay 50000}))

