bull-arena
Advanced tools
Comparing version 4.2.0 to 4.3.0
@@ -43,2 +43,4 @@ { | ||
"cm": "git cz", | ||
"dc:up": "docker-compose -f docker-compose.yml up -d", | ||
"dc:down": "docker-compose -f docker-compose.yml down", | ||
"dry:run": "npm publish --dry-run", | ||
@@ -70,3 +72,3 @@ "lint": "prettier -c .", | ||
"repository": "https://github.com/bee-queue/arena.git", | ||
"version": "4.2.0" | ||
"version": "4.3.0" | ||
} |
@@ -317,2 +317,34 @@ $(document).ready(() => { | ||
$('.js-update-job-data').on('click', function (e) { | ||
e.preventDefault(); | ||
const jobId = $(this).data('job-id'); | ||
const queueName = $(this).data('queue-name'); | ||
const queueHost = $(this).data('queue-host'); | ||
const stringifiedData = JSON.stringify(window.jsonEditor.get()); | ||
const r = window.confirm( | ||
`Update job #${jobId} data in queue "${queueHost}/${queueName}"?` | ||
); | ||
if (r) { | ||
$.ajax({ | ||
url: `${basePath}/api/queue/${encodeURIComponent( | ||
queueHost | ||
)}/${encodeURIComponent(queueName)}/job/${encodeURIComponent( | ||
jobId | ||
)}/data`, | ||
type: 'PUT', | ||
data: stringifiedData, | ||
contentType: 'application/json', | ||
}) | ||
.done(() => { | ||
alert('Job data successfully updated!'); | ||
window.location.reload(); | ||
}) | ||
.fail((jqXHR) => { | ||
window.alert('Failed to update job data, check console for error.'); | ||
console.error(jqXHR.responseText); | ||
}); | ||
} | ||
}); | ||
$('.js-add-flow').on('click', function () { | ||
@@ -319,0 +351,0 @@ const data = window.jsonEditor.get(); |
@@ -9,2 +9,3 @@ const router = require('express').Router(); | ||
const jobRemove = require('./jobRemove'); | ||
const jobDataUpdate = require('./jobDataUpdate'); | ||
const repeatableJobRemove = require('./repeatableJobRemove'); | ||
@@ -28,2 +29,3 @@ const bulkJobsPromote = require('./bulkJobsPromote'); | ||
); | ||
router.put('/queue/:queueHost/:queueName/job/:id/data', jobDataUpdate); | ||
router.patch('/queue/:queueHost/:queueName/job/:id', jobRetry); | ||
@@ -30,0 +32,0 @@ router.put('/queue/:queueHost/:queueName/pause', queuePause); |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
2144120
64
6010