summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--api.py7
1 files changed, 7 insertions, 0 deletions
diff --git a/api.py b/api.py
index 8559288..2dfa964 100644
--- a/api.py
+++ b/api.py
@@ -43,6 +43,12 @@ class Worker(object):
"""Finish a job."""
api = crawler.Crawler(self._apitoken)
logging.debug("%s: getting matches from API", jobid)
+ # if a player is queried, pass that information to processor
+ if "filter[playerNames]" in payload["params"]:
+ playername = payload["params"]["filter[playerNames]"]
+ else:
+ playername = ""
+
async with self._pool.acquire() as con:
async for data in api.matches(region=payload["region"],
params=payload["params"]):
@@ -54,6 +60,7 @@ class Worker(object):
priority=priority,
payload={
"id": matchid["id"],
+ "playername": playername
})
async def _work(self):