def METHOD_NAME(self):
    policies = [VersionedPolicyID(rule_id="rule1", version=1)]
    req = DeactivateFlowsRequest(
        sid=SubscriberID(id="imsi12345"),
        ip_addr="1.2.3.4",
        uplink_tunnel=0x1,
        downlink_tunnel=0x2,
        policies=policies,
    )
    ip_addr = IPAddress(
        version=IPAddress.IPV4,
        address=req.ip_addr.encode('utf-8'),
    )
    self.pipelined_srv.DeactivateFlows(req, MagicMock())
    assert self._enforcer_app.deactivate_rules.call_args.args[0] == req.sid.id
    assert self._enforcer_app.deactivate_rules.call_args.args[1].version == ip_addr.version
    assert self._enforcer_app.deactivate_rules.call_args.args[1].address == ip_addr.address
    assert self._enforcer_app.deactivate_rules.call_args.args[2] == ["rule1"]