Tweak for publisher errors

This commit is contained in:
2023-09-06 00:17:31 -07:00
parent a56d3b0b84
commit 5952c58f5a
2 changed files with 9 additions and 18 deletions

View File

@@ -899,18 +899,12 @@
nil)
(defn observable-query [query]
(mu/with-context {:query (:query query)
:args (:args query)
:query-stats true
:io-context ::hello}
(mu/trace ::query
[]
(let [query-results (dc/query {:query (:query query)
:args (:args query)
:query-stats true
:io-context ::hello})]
(alog/info ::query-stats
:io-stats (:io-stats query-results)
:query-stats (:query-stats query-results))
(:ret query-results)))))
(let [query-results (dc/query {:query (:query query)
:args (:args query)
:query-stats true
:io-context ::hello})]
#_(alog/info ::query-stats
:io-stats (:io-stats query-results)
:query-stats (:query-stats query-results))
(:ret query-results)))