diff --git a/datasette/database.py b/datasette/database.py index c5589881..2ba89923 100644 --- a/datasette/database.py +++ b/datasette/database.py @@ -657,9 +657,7 @@ class Database: start_time=task.enqueued_at_ns, **write_span_kwargs, ).end(end_time=dequeued_at_ns) - record_write_queue_wait( - self.name, dequeued_at_ns - task.enqueued_at_ns - ) + record_write_queue_wait(self.name, dequeued_at_ns - task.enqueued_at_ns) if conn_exception is not None: # fn never runs in this branch, so there is nothing to # wrap in a db.write.execute span. diff --git a/datasette/telemetry.py b/datasette/telemetry.py index f1570713..581787fe 100644 --- a/datasette/telemetry.py +++ b/datasette/telemetry.py @@ -578,9 +578,7 @@ def observe_write_queue_depth(options=None): if write_queue is None: # No write has ever been queued for this database. continue - yield otel_metrics.Observation( - write_queue.qsize(), {DB_NAMESPACE: db.name} - ) + yield otel_metrics.Observation(write_queue.qsize(), {DB_NAMESPACE: db.name}) def observe_open_connections(options=None):