зеркало из https://github.com/microsoft/ghcrawler.git
Merge pull request #166 from dabutvin/origin-queue
read originQueue queue name from request when queueing new requests
This commit is contained in:
Коммит
b37be19929
|
@ -2,6 +2,7 @@
|
||||||
// SPDX-License-Identifier: MIT
|
// SPDX-License-Identifier: MIT
|
||||||
|
|
||||||
const Policy = require('./traversalPolicy');
|
const Policy = require('./traversalPolicy');
|
||||||
|
const _ = require('lodash');
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Requests describe a resource to capture and process as well as the context for that processing.
|
* Requests describe a resource to capture and process as well as the context for that processing.
|
||||||
|
@ -201,7 +202,7 @@ class Request {
|
||||||
if (pruneRelation) {
|
if (pruneRelation) {
|
||||||
delete newRequest.context.relation;
|
delete newRequest.context.relation;
|
||||||
}
|
}
|
||||||
this.queueRequests(newRequest);
|
this.queueRequests(newRequest, _.get(this._originQueue, 'queue.name'));
|
||||||
}
|
}
|
||||||
|
|
||||||
markDead(outcome, message) {
|
markDead(outcome, message) {
|
||||||
|
@ -308,4 +309,4 @@ class Request {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
module.exports = Request;
|
module.exports = Request;
|
||||||
|
|
Загрузка…
Ссылка в новой задаче