def _forward_chunk()

in dualpipe/dualpipev.py [0:0]

• 7 lines of code
• 3 McCabe index (conditional complexity)

    def _forward_chunk(self, phase: int, recv: bool = True, send: bool = True) -> None:
        if recv:
            self._recv_forward(phase)
        self._commit_and_wait_comm()

        self._forward_compute_chunk(phase)

        if send:
            self._send_forward(phase)