Log the actual task names involved

backend-refactor
Sven Slootweg 3 years ago
parent 882863af10
commit 731e41996b

@ -5,10 +5,10 @@ const defaultValue = require("default-value");
module.exports = function (state) {
const queries = require("../queries")(state);
return function createDatabaseMutationAPI({ tx, item, taskVersion }) {
return function createDatabaseMutationAPI({ tx, item, taskVersion, task }) {
return {
createItem: function (options) {
console.log(`[new] ${options.id}`);
console.log(`[${task}][new] ${options.id}`);
return queries.createItem(tx, {
...options,

@ -124,7 +124,7 @@ module.exports = function (state) {
buffer(),
globalRateLimiter,
processTaskSafely(task, (item, tx) => {
console.log(`[started] ${item.id}`);
console.log(`[${task}][started] ${item.id}`);
let context = { tx, item, task, taskVersion };
@ -167,7 +167,7 @@ module.exports = function (state) {
expires_at: dateFns.add(new Date(), { seconds: ttlInSeconds })
});
}).catch((error) => {
console.warn(`[failed] ${item.id}`, error);
console.warn(`[${task}][failed] ${item.id}`, error);
return Promise.try(() => {
// Task failed -- note, cannot use tx here because it has failed

Loading…
Cancel
Save