                           [?job :job/catalog ?catalog]]
                   result (d/q query db (:db/id (:task payload-b)) (pr-str catalog-a))
                   jobs (map first result)]
-              (is (= (count jobs) 1)))))
+              (is (= (count jobs) 1))))
+          
+          (extensions/on-change sync (:status (:nodes payload-b)) #(>!! status-spy %))
+          (extensions/touch-place sync (:ack (:nodes payload-b)))
+
+          (<!! ack-ch-spy)
+          (<!! status-spy))
 
         (let [payload-a (extensions/read-place sync payload-node-a-2)]
           (extensions/write-place sync peer-node-a payload-node-a-1)

                          [?job :job/catalog ?catalog]]
                  result (d/q query db (:db/id (:task payload-a)) (pr-str catalog-b))
                  jobs (map first result)]
              (is (= (count jobs) 1)))))))
    
    {:eviction-delay 50000}))


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

        (let [db (d/db (:conn log))
              payload-a (extensions/read-place sync payload-node-a-1)
              payload-b (extensions/read-place sync payload-node-b-1)]

          (testing "Payload A is for job A"
            (let [query '[:find ?job :in $ ?task ?catalog :where
                          [?job :job/task ?task]
                          [?job :job/catalog ?catalog]]
                  result (d/q query db (:db/id (:task payload-a)) (pr-str catalog-a))
                  jobs (map first result)]
              (is (= (count jobs) 1))))

          (testing "Payload B is for job A"
            (let [query '[:find ?job :in $ ?task ?catalog :where
                          [?job :job/task ?task]
                          [?job :job/catalog ?catalog]]
                  result (d/q query db (:db/id (:task payload-b)) (pr-str catalog-a))
                  jobs (map first result)]
              (is (= (count jobs) 1))))

          (extensions/on-change sync (:status (:nodes payload-a)) #(>!! status-spy %))
          (extensions/on-change sync (:status (:nodes payload-b)) #(>!! status-spy %))
