     (is (= [{:certname_id 1 :type "hiera" :name "puppetdb::disable_cleartext"}
             {:certname_id 1 :type "hiera" :name "puppetdb::disable_ssl"}]
            (query-to-vec "select * from catalog_inputs")))
-    (is (= [{:id 1 :certname "foo" :catalog_inputs_timestamp stamp-2 :catalog_inputs_uuid (:catalog_uuid catalog)}]
+    (is (= [{:id id :certname "foo" :catalog_inputs_timestamp stamp-2 :catalog_inputs_uuid (:catalog_uuid catalog)}]
            (query-to-vec "select certname, id, catalog_inputs_timestamp, catalog_inputs_uuid::text from certnames")))))
 
 (defn get-lock-timeout []

    (is (= [{:certname_id 1 :type "hiera" :name "puppetdb::disable_cleartext"}
            {:certname_id 1 :type "hiera" :name "puppetdb::disable_ssl"}]
           (query-to-vec "select * from catalog_inputs")))
    (is (= [{:id 1 :certname "foo" :catalog_inputs_timestamp stamp-2 :catalog_inputs_uuid (:catalog_uuid catalog)}]
           (query-to-vec "select certname, id, catalog_inputs_timestamp, catalog_inputs_uuid::text from certnames")))

    ;; No effect if time is <=

                             stamp-1)
    (is (= [{:certname_id 1 :type "hiera" :name "puppetdb::globals::version"}]
           (query-to-vec "select * from catalog_inputs")))
    (is (= [{:id id :certname "foo" :catalog_inputs_timestamp stamp-1 :catalog_inputs_uuid (:catalog_uuid catalog)}]
           (query-to-vec "select certname, id, catalog_inputs_timestamp, catalog_inputs_uuid::text from certnames")))

    ;; Changes for newer time, removes old inputs, supports multiple inputs
