Send the initial request to the arbiter.
(self)
| 394 | return self._read_next_chunk() |
| 395 | |
| 396 | def _start_request(self): |
| 397 | """Send the initial request to the arbiter.""" |
| 398 | with self.client._lock: |
| 399 | if self.client._sock is None: |
| 400 | self.client.connect() |
| 401 | |
| 402 | # Set deadline for entire stream |
| 403 | now = time.monotonic() |
| 404 | self._deadline = now + self.client.timeout |
| 405 | self._last_chunk_time = now |
| 406 | |
| 407 | self._request_id = str(uuid.uuid4()) |
| 408 | request = make_request( |
| 409 | self._request_id, |
| 410 | self.app_path, |
| 411 | self.action, |
| 412 | args=self.args, |
| 413 | kwargs=self.kwargs, |
| 414 | ) |
| 415 | DirtyProtocol.write_message(self.client._sock, request) |
| 416 | |
| 417 | def _read_next_chunk(self): |
| 418 | """Read the next message from the stream.""" |
no test coverage detected