         (<!! sync-spy-a)
         (<!! sync-spy-b)
 
-        (let [payload-a (extensions/read-place sync payload-node-a-1)
+        (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)]
 
-          (let [db (d/db (:conn log))]
-            
-            (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)))))
+          (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 %))

                          [?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}))


                          [?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-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)
