docs: def _WriteFlowResponsesAndExpectedUpdates(self, responses, cursor=None):
      """Writes a flow responses and updates flow requests expected counts."""
  
      self._WriteResponses(responses, cursor)
  
      query = """
        UPDATE flow_requests
        SET responses_expected=%(responses_expected)s
        WHERE
          client_id = %(client_id)s AND
          flow_id = %(flow_id)s AND
          request_id = %(request_id)s
      """
  
      for r in responses:
        # If the response is a FlowStatus, we have to update the FlowRequest with
        # the number of expected messages.
        if isinstance(r, rdf_flow_objects.FlowStatus):
          args = {
              "client_id": db_utils.ClientIDToInt(r.client_id),
              "flow_id": db_utils.FlowIDToInt(r.flow_id),
              "request_id": r.request_id,
              "responses_expected": r.response_id,
          }
          cursor.execute(query, args)