rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-05-27 10:00:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

work_queue abstraction: typing fixes

Browse Source
This commit is contained in:
Christian Schwarz
2024-01-08 18:29:29 +00:00
parent 587493dbe1
commit 52e1d5605f
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
test_runner/fixtures/work_queue.py
View File

@@ -21,10 +21,10 @@ def do(nthreads: int, inputs: List[T], work_fn: Callable[[T], U]) -> List[U]:
if item is None:
return
output = work_fn(item._item)
output_queue.put(Item(output))
output_queue.put(output)
input_queue: queue.Queue[Optional["Item[T]"]] = queue.Queue()
output_queue: queue.Queue[Optional["Item[U]"]] = queue.Queue()
output_queue: queue.Queue[U] = queue.Queue()
for t in inputs:
input_queue.put(Item(t))
workers = []