3pp-mirror/penpot
1
0
Fork 0
mirror of https://github.com/penpot/penpot.git synced 2025-05-21 04:16:11 +02:00
Code Issues Projects Releases Packages Wiki Activity

📎 Add minor logging improvements on worker module

Browse source
This commit is contained in:
Andrey Antukh 2024-04-16 15:01:04 +02:00
parent c3a0db2431
commit 25001e5b80
3 changed files with 7 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

6
backend/src/app/worker.clj
View file

@ -119,11 +119,13 @@
:next.jdbc/update-count))] :next.jdbc/update-count))]
(l/trc :hint "submit task" (l/trc :hint "submit task"
:name task :name task
:task-id (str id)
:queue queue :queue queue
:label label :label label
:dedupe (boolean dedupe) :dedupe (boolean dedupe)
:deleted (or deleted 0) :delay (dt/format-duration duration)
:in (dt/format-duration duration)) :replace (or deleted 0))
(db/exec-one! conn [sql:insert-new-task id task props queue (db/exec-one! conn [sql:insert-new-task id task props queue
label priority max-retries interval]) label priority max-retries interval])

2
backend/src/app/worker/cron.clj
View file

@ -92,7 +92,7 @@
(let [ts (ms-until-valid cron) (let [ts (ms-until-valid cron)
ft (px/schedule! ts (partial execute-cron-task cfg task))] ft (px/schedule! ts (partial execute-cron-task cfg task))]
(l/dbg :hint "schedule task" :id id (l/dbg :hint "schedule" :id id
:ts (dt/format-duration ts) :ts (dt/format-duration ts)
:at (dt/format-instant (dt/in-future ts))) :at (dt/format-instant (dt/in-future ts)))

4
backend/src/app/worker/runner.clj
View file

@ -139,7 +139,7 @@
:else :else
(try (try
(l/trc :hint "start task" (l/trc :hint "start"
:name (:name task) :name (:name task)
:task-id (str task-id) :task-id (str task-id)
:queue queue :queue queue
@ -149,7 +149,7 @@
result (handle-task task) result (handle-task task)
elapsed (dt/format-duration (tpoint))] elapsed (dt/format-duration (tpoint))]
(l/trc :hint "end task" (l/trc :hint "end"
:name (:name task) :name (:name task)
:task-id (str task-id) :task-id (str task-id)
:queue queue :queue queue