w33ble/elastiq
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

use filter instead of must in query

Browse Source 
faster, and the score does not matter here
This commit is contained in:
Joe Fleming
2016-05-17 13:37:22 -07:00
parent 5f2e2b09cf
commit 89c08068dd
2 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/worker.js
View File

@@ -235,11 +235,11 @@ export default class Job extends events.EventEmitter {
constant_score: { constant_score: {
filter: { filter: {
bool: { bool: {
must: { term: { jobtype: this.jobtype } }, filter: { term: { jobtype: this.jobtype } },
should: [ should: [
{ term: { status: 'pending'} }, { term: { status: 'pending'} },
{ bool: { bool:
{ must: [ { filter: [
{ term: { status: 'processing' } }, { term: { status: 'processing' } },
{ range: { process_expiration: { lte: nowTime } } } { range: { process_expiration: { lte: nowTime } } }
] } ] }

5
test/src/worker.js
View File

@@ -231,8 +231,7 @@ describe('Worker class', function () {
it('should search by job type', function () { it('should search by job type', function () {
const { body } = getSearchParams(jobtype); const { body } = getSearchParams(jobtype);
const conditions = get(body, conditionPath); const conditions = get(body, conditionPath);
expect(conditions).to.have.property('must'); expect(conditions.filter).to.eql({ term: { jobtype: jobtype } });
expect(conditions.must).to.eql({ term: { jobtype: jobtype } });
}); });
it('should search for pending or expired jobs', function () { it('should search for pending or expired jobs', function () {
@@ -243,7 +242,7 @@ describe('Worker class', function () {
// this works because we are stopping the clock, so all times match // this works because we are stopping the clock, so all times match
const nowTime = moment().toISOString(); const nowTime = moment().toISOString();
const pending = { term: { status: 'pending'} }; const pending = { term: { status: 'pending'} };
const expired = { bool: { must: [ const expired = { bool: { filter: [
{ term: { status: 'processing' } }, { term: { status: 'processing' } },
{ range: { process_expiration: { lte: nowTime } } } { range: { process_expiration: { lte: nowTime } } }
] } }; ] } };