(self)
| 24 | print("TaskClient created: {} ({})".format(name, controller_address)) |
| 25 | |
| 26 | def get_indices(self) -> List[SampleIndex]: |
| 27 | result = requests.get( |
| 28 | self.controller_address + "/get_indices", params={"name": self.name} |
| 29 | ) |
| 30 | if result.status_code != 200: |
| 31 | raise AgentBenchException(result.text, result.status_code, self.name) |
| 32 | return result.json() |
| 33 | |
| 34 | def get_concurrency(self) -> int: |
| 35 | try: |
no test coverage detected