mirror of
https://github.com/internetarchive/brozzler.git
synced 2025-02-24 08:39:59 -05:00
add logger name to event dict
This commit is contained in:
parent
564307c7f8
commit
45f352dc86
@ -147,7 +147,7 @@ def behavior_script(url, template_parameters=None, behaviors_dir=None):
|
|||||||
|
|
||||||
|
|
||||||
class ThreadExceptionGate:
|
class ThreadExceptionGate:
|
||||||
logger = structlog.get_logger(__module__ + "." + __qualname__)
|
logger = structlog.get_logger(logger_name=__module__ + "." + __qualname__)
|
||||||
|
|
||||||
def __init__(self, thread):
|
def __init__(self, thread):
|
||||||
self.thread = thread
|
self.thread = thread
|
||||||
|
@ -53,7 +53,7 @@ class BrowserPool:
|
|||||||
debugging protocol.
|
debugging protocol.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
logger = structlog.get_logger(__module__ + "." + __qualname__)
|
logger = structlog.get_logger(logger_name=__module__ + "." + __qualname__)
|
||||||
|
|
||||||
def __init__(self, size=3, **kwargs):
|
def __init__(self, size=3, **kwargs):
|
||||||
"""
|
"""
|
||||||
@ -144,7 +144,7 @@ class BrowserPool:
|
|||||||
|
|
||||||
|
|
||||||
class WebsockReceiverThread(threading.Thread):
|
class WebsockReceiverThread(threading.Thread):
|
||||||
logger = structlog.get_logger(__module__ + "." + __qualname__)
|
logger = structlog.get_logger(logger_name=__module__ + "." + __qualname__)
|
||||||
|
|
||||||
def __init__(self, websock, name=None, daemon=True):
|
def __init__(self, websock, name=None, daemon=True):
|
||||||
super().__init__(name=name, daemon=daemon)
|
super().__init__(name=name, daemon=daemon)
|
||||||
@ -322,7 +322,7 @@ class Browser:
|
|||||||
Manages an instance of Chrome for browsing pages.
|
Manages an instance of Chrome for browsing pages.
|
||||||
"""
|
"""
|
||||||
|
|
||||||
logger = structlog.get_logger(__module__ + "." + __qualname__)
|
logger = structlog.get_logger(logger_name=__module__ + "." + __qualname__)
|
||||||
|
|
||||||
def __init__(self, **kwargs):
|
def __init__(self, **kwargs):
|
||||||
"""
|
"""
|
||||||
|
@ -65,7 +65,7 @@ def check_version(chrome_exe):
|
|||||||
|
|
||||||
|
|
||||||
class Chrome:
|
class Chrome:
|
||||||
logger = structlog.get_logger(__module__ + "." + __qualname__)
|
logger = structlog.get_logger(logger_name=__module__ + "." + __qualname__)
|
||||||
|
|
||||||
def __init__(self, chrome_exe, port=9222, ignore_cert_errors=False):
|
def __init__(self, chrome_exe, port=9222, ignore_cert_errors=False):
|
||||||
"""
|
"""
|
||||||
|
@ -156,7 +156,7 @@ class ThreadingWSGIServer(
|
|||||||
|
|
||||||
|
|
||||||
class BrozzlerEasyController:
|
class BrozzlerEasyController:
|
||||||
logger = structlog.get_logger(__module__ + "." + __qualname__)
|
logger = structlog.get_logger(logger_name=__module__ + "." + __qualname__)
|
||||||
|
|
||||||
def __init__(self, args):
|
def __init__(self, args):
|
||||||
self.stop = threading.Event()
|
self.stop = threading.Event()
|
||||||
|
@ -33,7 +33,7 @@ class UnexpectedDbResult(Exception):
|
|||||||
|
|
||||||
|
|
||||||
class RethinkDbFrontier:
|
class RethinkDbFrontier:
|
||||||
logger = structlog.get_logger(__module__ + "." + __qualname__)
|
logger = structlog.get_logger(logger_name=__module__ + "." + __qualname__)
|
||||||
|
|
||||||
def __init__(self, rr, shards=None, replicas=None):
|
def __init__(self, rr, shards=None, replicas=None):
|
||||||
self.rr = rr
|
self.rr = rr
|
||||||
|
@ -194,7 +194,7 @@ class ElapsedMixIn(object):
|
|||||||
|
|
||||||
|
|
||||||
class Job(doublethink.Document, ElapsedMixIn):
|
class Job(doublethink.Document, ElapsedMixIn):
|
||||||
logger = structlog.get_logger(__module__ + "." + __qualname__)
|
logger = structlog.get_logger(logger_name=__module__ + "." + __qualname__)
|
||||||
table = "jobs"
|
table = "jobs"
|
||||||
|
|
||||||
def populate_defaults(self):
|
def populate_defaults(self):
|
||||||
@ -223,7 +223,7 @@ class Job(doublethink.Document, ElapsedMixIn):
|
|||||||
|
|
||||||
|
|
||||||
class Site(doublethink.Document, ElapsedMixIn):
|
class Site(doublethink.Document, ElapsedMixIn):
|
||||||
logger = structlog.get_logger(__module__ + "." + __qualname__)
|
logger = structlog.get_logger(logger_name=__module__ + "." + __qualname__)
|
||||||
table = "sites"
|
table = "sites"
|
||||||
|
|
||||||
def populate_defaults(self):
|
def populate_defaults(self):
|
||||||
@ -379,7 +379,7 @@ class Site(doublethink.Document, ElapsedMixIn):
|
|||||||
|
|
||||||
|
|
||||||
class Page(doublethink.Document):
|
class Page(doublethink.Document):
|
||||||
logger = structlog.get_logger(__module__ + "." + __qualname__)
|
logger = structlog.get_logger(logger_name=__module__ + "." + __qualname__)
|
||||||
table = "pages"
|
table = "pages"
|
||||||
|
|
||||||
@staticmethod
|
@staticmethod
|
||||||
|
Loading…
x
Reference in New Issue
Block a user