File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 66"""
77from __future__ import annotations
88
9- import contextlib
109import json
1110import logging
1211import os
@@ -283,7 +282,6 @@ def _get_spawn_cap() -> int:
283282
284283try :
285284 import fcntl
286- import signal
287285 _HAS_FCNTL = True
288286except ImportError :
289287 _HAS_FCNTL = False
Original file line number Diff line number Diff line change @@ -1148,12 +1148,12 @@ def _drain_batch_from_backlog(markers: list[Path]) -> None:
11481148
11491149def _start_backlog_drainer () -> None :
11501150 """Launch the background backlog drainer thread."""
1151- if _BACKLOG_DRAIN_INTERVAL <= 0 :
1151+ if _BACKLOG_DRAIN_INTERVAL_NORMAL <= 0 :
11521152 log .info ("Backlog drainer disabled (TRUEMEMORY_DRAIN_INTERVAL_SEC=0)" )
11531153 return
11541154 t = threading .Thread (target = _backlog_drainer , daemon = True , name = "backlog-drainer" )
11551155 t .start ()
1156- log .info ("Backlog drainer started (interval=%ds)" , _BACKLOG_DRAIN_INTERVAL )
1156+ log .info ("Backlog drainer started (interval=%ds)" , _BACKLOG_DRAIN_INTERVAL_NORMAL )
11571157
11581158
11591159# ---------------------------------------------------------------------------
You can’t perform that action at this time.
0 commit comments