diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-21 18:06:06 +0100 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-21 18:06:06 +0100 |
| commit | 42d06bc2da87f2c7805c2e693dde9a90ca5476e1 (patch) | |
| tree | a2e10e8237729072d96fb31f786d080cc4cbc4cb | |
| parent | d7c8d99fd0ce79ecf73383ea4dbd5f0df3266099 (diff) | |
| download | bridge-42d06bc2da87f2c7805c2e693dde9a90ca5476e1.tar.gz bridge-42d06bc2da87f2c7805c2e693dde9a90ca5476e1.zip | |
don't insert new grab jobs until compiler is done
| -rw-r--r-- | api.js | 7 |
1 files changed, 6 insertions, 1 deletions
@@ -143,7 +143,12 @@ app.get("/api/player/:name", async (req, res) => { var job = await raw.query(` UPDATE jobs SET priority=0 - WHERE payload=$1 AND status<>'finished' + WHERE + ( + (type='grab' AND payload=$1) OR + (type='process' AND payload->>'playername'=$1->'params'->>'filter[playerNames]') OR + (type='compile' AND payload->>'type'='player' AND payload->>'id'=$1->'params'->>'filter[playerIds]') + ) AND status<>'finished' AND status<>'failed' RETURNING id `, [payload]); if (job.rows.length == 0) { |
