From 65f927122b985a9af434031f1685af905badd8f6 Mon Sep 17 00:00:00 2001 From: Neil Booth Date: Mon, 16 Jan 2017 21:21:26 +0900 Subject: [PATCH] daemon: properly check for HTTP status codes --- server/daemon.py | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/server/daemon.py b/server/daemon.py index 39cb857..783dfba 100644 --- a/server/daemon.py +++ b/server/daemon.py @@ -70,10 +70,13 @@ class Daemon(util.LoggedClass): async with self.workqueue_semaphore: url = self.urls[self.url_index] async with aiohttp.post(url, data=data) as resp: - result = processor(await resp.json()) - if self.prior_msg: - self.logger.info('connection restored') - return result + if resp.status == 200: + if self.prior_msg: + self.logger.info('connection restored') + result = processor(await resp.json()) + return result + log_error('HTTP error code {:d}: {}' + .format(resp.status, resp.reason)) except asyncio.TimeoutError: log_error('timeout error.', skip_once=True) except aiohttp.ClientHttpProcessingError: