feat(xo-server/backup-ng): log scheduled VMs if concurrency above 0 (#3633)
See #3603
This commit is contained in:
15
packages/xo-server/src/schemas/log/taskInfo.js
Normal file
15
packages/xo-server/src/schemas/log/taskInfo.js
Normal file
@@ -0,0 +1,15 @@
|
||||
export default {
|
||||
$schema: 'http://json-schema.org/draft-04/schema#',
|
||||
type: 'object',
|
||||
properties: {
|
||||
event: {
|
||||
enum: ['task.info'],
|
||||
},
|
||||
taskId: {
|
||||
type: 'string',
|
||||
description: 'identifier of the parent task or job',
|
||||
},
|
||||
data: {},
|
||||
},
|
||||
required: ['event', 'taskId'],
|
||||
}
|
||||
@@ -129,6 +129,13 @@ export default {
|
||||
data: data.data,
|
||||
message,
|
||||
})
|
||||
} else if (event === 'task.info') {
|
||||
const parent = started[data.taskId]
|
||||
parent !== undefined &&
|
||||
(parent.infos || (parent.infos = [])).push({
|
||||
data: data.data,
|
||||
message,
|
||||
})
|
||||
} else if (event === 'jobCall.start') {
|
||||
const parent = started[data.runJobId]
|
||||
if (parent !== undefined) {
|
||||
|
||||
@@ -646,6 +646,13 @@ export default class BackupNg {
|
||||
])
|
||||
if (concurrency !== 0) {
|
||||
handleVm = limitConcurrency(concurrency)(handleVm)
|
||||
logger.notice('vms', {
|
||||
event: 'task.info',
|
||||
taskId: runJobId,
|
||||
data: {
|
||||
vms: vms.map(vm => vm.id),
|
||||
},
|
||||
})
|
||||
}
|
||||
await asyncMap(vms, handleVm)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user