(
vdataType: str,
edataType: str,
app_type: str,
directed: bool,
jar_path: str,
java_app_class: str,
param_str,
)
| 166 | |
| 167 | |
| 168 | def run_app( |
| 169 | vdataType: str, |
| 170 | edataType: str, |
| 171 | app_type: str, |
| 172 | directed: bool, |
| 173 | jar_path: str, |
| 174 | java_app_class: str, |
| 175 | param_str, |
| 176 | ): |
| 177 | sess = graphscope.session(cluster_type="hosts", num_workers=1) |
| 178 | graph = sess.g(directed=directed) |
| 179 | graph = load_p2p_network(sess) |
| 180 | |
| 181 | if "simple" in app_type: |
| 182 | graph = graph.project(vertices={"host": ['id']}, edges={"connect": ["dist"]}) |
| 183 | app = JavaApp(full_jar_path=jar_path, java_app_class=java_app_class) |
| 184 | exec("ctx=app(graph, {})".format(param_str)) |
| 185 | logger.info("Successfully verify app: {}".format(java_app_class)) |
| 186 | |
| 187 | |
| 188 | if __name__ == "__main__": |
no test coverage detected