Skip to content

Commit 460a871

Browse files
committed
update tests for atomic counter
1 parent e0e440a commit 460a871

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

pychunkedgraph/tests/test_uncategorized.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -116,6 +116,8 @@ def test_build_single_node(self, gen_graph):
116116
cg = gen_graph(n_layers=2)
117117
# Add Chunk A
118118
create_chunk(cg, vertices=[to_label(cg, 1, 0, 0, 0, 0)])
119+
chunk_id = to_label(cg, 1, 0, 0, 0, 0)
120+
assert cg.id_client.get_max_node_id(chunk_id) == chunk_id
119121

120122
res = cg.client._table.read_rows()
121123
res.consume_all()
@@ -160,6 +162,8 @@ def test_build_single_edge(self, gen_graph):
160162
vertices=[to_label(cg, 1, 0, 0, 0, 0), to_label(cg, 1, 0, 0, 0, 1)],
161163
edges=[(to_label(cg, 1, 0, 0, 0, 0), to_label(cg, 1, 0, 0, 0, 1), 0.5)],
162164
)
165+
chunk_id = to_label(cg, 1, 0, 0, 0, 0)
166+
assert cg.id_client.get_max_node_id(chunk_id) == to_label(cg, 1, 0, 0, 0, 1)
163167

164168
res = cg.client._table.read_rows()
165169
res.consume_all()
@@ -320,13 +324,19 @@ def test_build_single_edge_and_single_across_edge(self, gen_graph):
320324
],
321325
)
322326

327+
chunk_id = to_label(cg, 1, 0, 0, 0, 0)
328+
assert cg.id_client.get_max_node_id(chunk_id) == to_label(cg, 1, 0, 0, 0, 1)
329+
323330
# Chunk B
324331
create_chunk(
325332
cg,
326333
vertices=[to_label(cg, 1, 1, 0, 0, 0)],
327334
edges=[(to_label(cg, 1, 1, 0, 0, 0), to_label(cg, 1, 0, 0, 0, 0), inf)],
328335
)
329336

337+
chunk_id = to_label(cg, 1, 1, 0, 0, 0)
338+
assert cg.id_client.get_max_node_id(chunk_id) == to_label(cg, 1, 1, 0, 0, 0)
339+
330340
add_layer(cg, 3, np.array([0, 0, 0]), n_threads=1)
331341
res = cg.client._table.read_rows()
332342
res.consume_all()

0 commit comments

Comments
 (0)