From 1bc393cdc26bbaa9b2927cb4614784d185a7bb27 Mon Sep 17 00:00:00 2001
From: "bozo.kopic" <bozo.kopic@gmail.com>
Date: Thu, 17 Aug 2017 15:17:40 +0200
Subject: backend

---
 src_py/hatter/server.py | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

(limited to 'src_py/hatter/server.py')

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):
-- 
cgit v1.2.3-70-g09d2