diff options
| author | bozo.kopic <bozo.kopic@gmail.com> | 2017-08-17 15:17:40 +0200 |
|---|---|---|
| committer | bozo.kopic <bozo.kopic@gmail.com> | 2017-08-17 15:17:40 +0200 |
| commit | 1bc393cdc26bbaa9b2927cb4614784d185a7bb27 (patch) | |
| tree | ea9ab04949012c46eb9d926d9764dd98022a3592 /src_py/hatter/server.py | |
| parent | 074b604076049fb809c22ec0afaf18f5b55cc3ca (diff) | |
backend
Diffstat (limited to 'src_py/hatter/server.py')
| -rw-r--r-- | src_py/hatter/server.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src_py/hatter/server.py b/src_py/hatter/server.py index 9e44a0b..1ca9483 100644 --- a/src_py/hatter/server.py +++ b/src_py/hatter/server.py @@ -1,8 +1,9 @@ import asyncio import json -import collections import aiohttp.web +from hatter import util + async def create_web_server(backend, host, port, webhook_path, web_path): srv = WebServer() @@ -44,7 +45,7 @@ class WebServer: data = json.loads(body) req = _parse_webhook_request(request.headers, data) for commit in req.commits: - self._backend.enqueue(req.url, commit) + self._backend.add_job(req.url, commit) except Exception: pass return aiohttp.web.Response() @@ -59,7 +60,7 @@ class Client: pass -WebhookRequest = collections.namedtuple('WebhookRequest', ['url', 'commits']) +WebhookRequest = util.namedtuple('WebhookRequest', 'url', 'commits') def _parse_webhook_request(headers, data): |