(http_port: int, api_key: str)
| 483 | |
| 484 | |
| 485 | def create_worker(http_port: int, api_key: str) -> Tuple[str, str]: |
| 486 | url = f"http://127.0.0.1:{http_port}/api/v1/workers" |
| 487 | result = api_request(url, method="POST", data={"type": "normal"}, api_key=api_key) |
| 488 | |
| 489 | node_id = result.get("node_id") |
| 490 | worker_secret = result.get("worker_secret") |
| 491 | if not node_id or not worker_secret: |
| 492 | fatal("worker", f"Unexpected response: {json.dumps(result)}") |
| 493 | |
| 494 | info(f"Worker created: {node_id}") |
| 495 | return node_id, worker_secret |
| 496 | |
| 497 | |
| 498 | # --------------------------------------------------------------------------- |
no test coverage detected