From 7f88dda0aebc39ca7c613cd1d955c36ccde147cb Mon Sep 17 00:00:00 2001 From: Victor Shyba Date: Sat, 5 May 2018 02:18:03 -0300 Subject: [PATCH] use treq on loggly --- lbrynet/core/log_support.py | 13 +++++-------- 1 file changed, 5 insertions(+), 8 deletions(-) diff --git a/lbrynet/core/log_support.py b/lbrynet/core/log_support.py index a7a46dfeb..9e0a635d1 100644 --- a/lbrynet/core/log_support.py +++ b/lbrynet/core/log_support.py @@ -6,8 +6,7 @@ import os import sys import traceback -from txrequests import Session -from requests.exceptions import ConnectionError +import treq from twisted.internet import defer import twisted.python.log @@ -35,13 +34,13 @@ TRACE = 5 class HTTPSHandler(logging.Handler): - def __init__(self, url, fqdn=False, localname=None, facility=None, session=None): + def __init__(self, url, fqdn=False, localname=None, facility=None, cookies=None): logging.Handler.__init__(self) self.url = url self.fqdn = fqdn self.localname = localname self.facility = facility - self.session = session if session is not None else Session() + self.cookies = cookies or {} def get_full_message(self, record): if record.exc_info: @@ -52,10 +51,8 @@ class HTTPSHandler(logging.Handler): @defer.inlineCallbacks def _emit(self, record): payload = self.format(record) - try: - yield self.session.post(self.url, data=payload) - except ConnectionError: - pass + response = yield treq.post(self.url, data=payload, cookies=self.cookies) + self.cookies.update(response.cookies()) def emit(self, record): return self._emit(record)