(name, meta = {})
| 313 | } |
| 314 | |
| 315 | getWorkerMetadata(name, meta = {}) { |
| 316 | debug('getWorkerMetadata', name, { meta }); |
| 317 | |
| 318 | if (!this._init) |
| 319 | throw new Error( |
| 320 | 'bree.init() was not called, see <https://github.com/breejs/bree/blob/master/UPGRADING.md#upgrading-from-v8-to-v9>' |
| 321 | ); |
| 322 | |
| 323 | const job = this.config.jobs.find((j) => j.name === name); |
| 324 | if (!job) { |
| 325 | throw new Error(`Job "${name}" does not exist`); |
| 326 | } |
| 327 | |
| 328 | if (!this.config.outputWorkerMetadata && !job.outputWorkerMetadata) { |
| 329 | return meta && (meta.err !== undefined || meta.message !== undefined) |
| 330 | ? meta |
| 331 | : undefined; |
| 332 | } |
| 333 | |
| 334 | if (this.workers.has(name)) { |
| 335 | const worker = this.workers.get(name); |
| 336 | |
| 337 | return { |
| 338 | ...meta, |
| 339 | worker: { |
| 340 | isMainThread: worker.isMainThread, |
| 341 | resourceLimits: worker.resourceLimits, |
| 342 | threadId: worker.threadId |
| 343 | } |
| 344 | }; |
| 345 | } |
| 346 | |
| 347 | return meta; |
| 348 | } |
| 349 | |
| 350 | async run(name) { |
| 351 | debug('run', name); |
no outgoing calls
no test coverage detected