(
demo_jar,
graphscope_session,
projected_graph_sssp_class,
)
| 171 | ) |
| 172 | @pytest.mark.timeout(3600) |
| 173 | def test_giraph_app( |
| 174 | demo_jar, |
| 175 | graphscope_session, |
| 176 | projected_graph_sssp_class, |
| 177 | ): |
| 178 | graphscope_session.add_lib(demo_jar) |
| 179 | vformat = "giraph:com.alibaba.graphscope.example.giraph.format.P2PVertexInputFormat" |
| 180 | eformat = "giraph:com.alibaba.graphscope.example.giraph.format.P2PEdgeInputFormat" |
| 181 | g = projected_p2p_graph_loaded_by_giraph( |
| 182 | graphscope_session, demo_jar, vformat, eformat |
| 183 | ) |
| 184 | |
| 185 | giraph_sssp = load_app(algo="giraph:com.alibaba.graphscope.example.giraph.SSSP") |
| 186 | ctx = giraph_sssp(g, sourceId=6) |
| 187 | frame = ctx.to_dataframe({"id": "v.id", "r": "r"}) |
| 188 | |
| 189 | |
| 190 | @pytest.mark.skipif( |
nothing calls this directly
no test coverage detected