def METHOD_NAME(self, extra_flows):
    msg_list = []
    for tbl in extra_flows:
        for flow in extra_flows[tbl]:
            match = ovs_flow_match_to_magma_match(flow)
            self.logger.debug(
                'Sending msg for deletion -> %s',
                match.ryu_match,
            )
            msg_list.append(
                flows.get_delete_flow_msg(
                    self._datapath, tbl, match, cookie=flow.cookie,
                    cookie_mask=flows.OVS_COOKIE_MATCH_ALL,
                ),
            )
    if msg_list:
        chan = self._msg_hub.send(msg_list, self._datapath)
        self._wait_for_responses(chan, len(msg_list))