Skip to content

Commit fa28132

Browse files
Kasper JungeRalphify
authored andcommitted
style: drop unnecessary _queue import alias in _agent.py
The `queue` stdlib module was imported as `_queue` for no apparent reason — there is no name collision and the sister module `_events.py` imports it without an alias. Rename to plain `import queue` for consistency. Co-authored-by: Ralphify <noreply@ralphify.co>
1 parent 002bca2 commit fa28132

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

src/ralphify/_agent.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@
1717

1818
import json
1919
import os
20-
import queue as _queue
20+
import queue
2121
import signal
2222
import subprocess
2323
import threading
@@ -275,7 +275,7 @@ def _supports_stream_json(cmd: list[str]) -> bool:
275275

276276
def _readline_pump(
277277
stdout: IO[str],
278-
line_queue: _queue.Queue[str | None],
278+
line_queue: queue.Queue[str | None],
279279
) -> None:
280280
"""Read *stdout* line-by-line and put each line into *line_queue*.
281281
@@ -326,7 +326,7 @@ def _read_agent_stream(
326326
stdout_lines: list[str] = []
327327
result_text: str | None = None
328328

329-
line_q: _queue.Queue[str | None] = _queue.Queue()
329+
line_q: queue.Queue[str | None] = queue.Queue()
330330
reader = threading.Thread(target=_readline_pump, args=(stdout, line_q), daemon=True)
331331
reader.start()
332332

@@ -344,7 +344,7 @@ def _read_agent_stream(
344344

345345
try:
346346
line = line_q.get(timeout=get_timeout)
347-
except _queue.Empty:
347+
except queue.Empty:
348348
# Deadline expired while waiting for a line.
349349
return _StreamResult(
350350
stdout_lines=stdout_lines,

0 commit comments

Comments
 (0)