summaryrefslogtreecommitdiff
path: root/api.py
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-03-11 09:13:16 +0100
committerschneefux <schneefux+commit@schneefux.xyz>2017-03-11 09:13:16 +0100
commitffb51c6327c9000a15d42d9101d0f10976c686d5 (patch)
tree4653193e18461e86b9f4673b5e0a83bba4faf5e3 /api.py
parent25fbfa1fbd7d1c9f99df56de6481fbb0d77951ea (diff)
downloadprocessor-ffb51c6327c9000a15d42d9101d0f10976c686d5.tar.gz
processor-ffb51c6327c9000a15d42d9101d0f10976c686d5.zip
request only compile.player, analyze.participant
Diffstat (limited to 'api.py')
-rw-r--r--api.py11
1 files changed, 7 insertions, 4 deletions
diff --git a/api.py b/api.py
index 16b3a3a..b28d9dc 100644
--- a/api.py
+++ b/api.py
@@ -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)