Skip to content

Commit 065e378

Browse files
committed
format
Signed-off-by: Robert Kruszewski <github@robertk.io>
1 parent e9d0b00 commit 065e378

5 files changed

Lines changed: 5 additions & 19 deletions

File tree

docs/conf.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -58,9 +58,7 @@
5858
nitpicky = True # ensures all :class:, :obj:, etc. links are valid
5959
nitpick_ignore = []
6060

61-
doctest_global_setup = (
62-
"import pyarrow; import vortex; import vortex as vx; import random; random.seed(a=0)"
63-
)
61+
doctest_global_setup = "import pyarrow; import vortex; import vortex as vx; import random; random.seed(a=0)"
6462
doctest_default_flags = (
6563
doctest.ELLIPSIS | doctest.IGNORE_EXCEPTION_DETAIL | doctest.DONT_ACCEPT_TRUE_FOR_1 | doctest.NORMALIZE_WHITESPACE
6664
)

vortex-python/benchmark/test_aggregation.py

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -23,13 +23,7 @@ def test_arrow_table_aggregation(benchmark: BenchmarkFixture, vxf: vx.VortexFile
2323
for field in vxf.dtype.to_arrow_schema() # pyright: ignore[reportUnknownVariableType]
2424
if _has_mean(field.type) # pyright: ignore[reportUnknownMemberType, reportUnknownArgumentType]
2525
]
26-
benchmark(
27-
lambda: (
28-
pa.concat_tables(x.to_arrow_table() for x in vxf.scan())
29-
.group_by([])
30-
.aggregate(aggregations)
31-
)
32-
)
26+
benchmark(lambda: pa.concat_tables(x.to_arrow_table() for x in vxf.scan()).group_by([]).aggregate(aggregations))
3327

3428

3529
@pytest.mark.benchmark(group="aggregation", disable_gc=True)

vortex-python/benchmark/test_filter.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -13,9 +13,7 @@
1313

1414
@pytest.mark.benchmark(group="filter", disable_gc=True)
1515
def test_scan_filter(benchmark: BenchmarkFixture, vxf: vx.VortexFile):
16-
benchmark(
17-
lambda: pa.concat_tables(x.to_arrow_table() for x in vxf.scan(expr=column("x") >= 50_000))
18-
)
16+
benchmark(lambda: pa.concat_tables(x.to_arrow_table() for x in vxf.scan(expr=column("x") >= 50_000)))
1917

2018

2119
@pytest.mark.benchmark(group="filter", disable_gc=True)

vortex-python/benchmark/test_scalar_at.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -11,9 +11,7 @@
1111

1212
@pytest.mark.benchmark(group="scalar_at", disable_gc=True)
1313
def test_scan_scalar_at(benchmark: BenchmarkFixture, vxf: vx.VortexFile):
14-
benchmark(
15-
lambda: pa.concat_tables(x.to_arrow_table() for x in vxf.scan(indices=vx.array([50_000])))
16-
)
14+
benchmark(lambda: pa.concat_tables(x.to_arrow_table() for x in vxf.scan(indices=vx.array([50_000]))))
1715

1816

1917
@pytest.mark.benchmark(group="scalar_at", disable_gc=True)

vortex-python/clickbench.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -632,9 +632,7 @@ def _iter():
632632
arr = vx.Array.from_arrow(arr)
633633
yield arr
634634

635-
it = vx.ArrayIterator.from_iter(
636-
vx.DType.from_arrow(pf.schema_arrow, non_nullable=True), _iter()
637-
)
635+
it = vx.ArrayIterator.from_iter(vx.DType.from_arrow(pf.schema_arrow, non_nullable=True), _iter())
638636
vx.io.write(it, vx_path)
639637

640638
lf = vx.open(vx_path).to_polars()

0 commit comments

Comments
 (0)