Skip to content

Commit

Permalink
CORE-2006: addressed some review comments
Browse files Browse the repository at this point in the history
  • Loading branch information
slr71 committed Aug 6, 2024
1 parent fe49ed0 commit cc29658
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions src/data_info/clients/async_tasks.clj
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,8 @@
(defn run-async-thread
[async-task-id thread-function prefix]
(let [^Runnable task-thread (fn [] (thread-function async-task-id))]
(.start (Thread. task-thread (str prefix "-" (string/replace async-task-id #".*/tasks/" ""))))))
(.start (Thread. task-thread (str prefix "-" (string/replace async-task-id #".*/tasks/" "")))))
async-task-id)

(defn create-update-fn [async-task-id pool]
(fn [path action]
Expand Down Expand Up @@ -109,4 +110,5 @@
add-completed-status async-task-id
{:status "failed"
:detail (format "[%s] %s" (config/service-identifier) (pr-str (:throwable &throw-context)))}))
(end-fn async-task true))))))
(end-fn async-task true))))
(log/info "Finished processing async task " async-task-id)))

0 comments on commit cc29658

Please sign in to comment.