🔄 synced local 'logfire/' with remote 'logfire/'

Author: constient-altrova

logfire/handler.py

@@ -8,7 +8,7 @@
 from .uploader import Uploader
 from .frame import create_frame
 
-DEFAULT_HOST = 'https://in.logfire.sh'
+DEFAULT_HOST = "https://in.logfire.ai"
 DEFAULT_BUFFER_CAPACITY = 1000
 DEFAULT_FLUSH_INTERVAL = 1
 DEFAULT_RAISE_EXCEPTIONS = False
@@ -17,16 +17,18 @@
 
 
 class LogfireHandler(logging.Handler):
-    def __init__(self,
-                 source_token,
-                 host=DEFAULT_HOST,
-                 buffer_capacity=DEFAULT_BUFFER_CAPACITY,
-                 flush_interval=DEFAULT_FLUSH_INTERVAL,
-                 raise_exceptions=DEFAULT_RAISE_EXCEPTIONS,
-                 drop_extra_events=DEFAULT_DROP_EXTRA_EVENTS,
-                 include_extra_attributes=DEFAULT_INCLUDE_EXTRA_ATTRIBUTES,
-                 context=DEFAULT_CONTEXT,
-                 level=logging.NOTSET):
+    def __init__(
+        self,
+        source_token,
+        host=DEFAULT_HOST,
+        buffer_capacity=DEFAULT_BUFFER_CAPACITY,
+        flush_interval=DEFAULT_FLUSH_INTERVAL,
+        raise_exceptions=DEFAULT_RAISE_EXCEPTIONS,
+        drop_extra_events=DEFAULT_DROP_EXTRA_EVENTS,
+        include_extra_attributes=DEFAULT_INCLUDE_EXTRA_ATTRIBUTES,
+        context=DEFAULT_CONTEXT,
+        level=logging.NOTSET,
+    ):
         super(LogfireHandler, self).__init__(level=level)
         self.source_token = source_token
         self.host = host
@@ -40,10 +42,7 @@ def __init__(self,
         self.raise_exceptions = raise_exceptions
         self.dropcount = 0
         self.flush_thread = FlushWorker(
-            self.uploader,
-            self.pipe,
-            self.buffer_capacity,
-            self.flush_interval
+            self.uploader, self.pipe, self.buffer_capacity, self.flush_interval
         )
         if self._is_main_process():
             self.flush_thread.start()
@@ -56,7 +55,12 @@ def emit(self, record):
             if self._is_main_process() and not self.flush_thread.is_alive():
                 self.flush_thread.start()
             message = self.format(record)
-            frame = create_frame(record, message, self.context, include_extra_attributes=self.include_extra_attributes)
+            frame = create_frame(
+                record,
+                message,
+                self.context,
+                include_extra_attributes=self.include_extra_attributes,
+            )
             try:
                 self.pipe.put(frame, block=(not self.drop_extra_events))
             except queue.Full:
@@ -66,4 +70,4 @@ def emit(self, record):
                 pass
         except Exception as e:
             if self.raise_exceptions:
-                raise e
+                raise e