diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-11 09:13:16 +0100 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-03-11 09:13:16 +0100 |
| commit | ffb51c6327c9000a15d42d9101d0f10976c686d5 (patch) | |
| tree | 4653193e18461e86b9f4673b5e0a83bba4faf5e3 | |
| parent | 25fbfa1fbd7d1c9f99df56de6481fbb0d77951ea (diff) | |
| download | shrinker-ffb51c6327c9000a15d42d9101d0f10976c686d5.tar.gz shrinker-ffb51c6327c9000a15d42d9101d0f10976c686d5.zip | |
request only compile.player, analyze.participant
| -rw-r--r-- | api.py | 11 |
1 files changed, 7 insertions, 4 deletions
@@ -134,16 +134,19 @@ class Processor(joblib.worker.Worker): True) # critical logging.debug("record processed") - if obj_id: + if obj_id is not None: # run web->web queries payload = { "type": table, "id": obj_id } - logging.debug("requested jobs for %s", obj_id) + logging.debug("%s: requesting jobs for %s", + jobid, obj_id) self._priorities.append(priority) - self._compilejobs.append(payload) - self._analyzejobs.append(payload) + if table == "player": + self._compilejobs.append(payload) + if table == "participant": + self._analyzejobs.append(payload) if lmcd is not None: self._preloadpriorities.append(priority+1) |
