

def connect(self, rt, actor_id, port_name, peer_node_id, peer_actor_id, peer_port_name, timeout=DEFAULT_TIMEOUT, async=False):
    data = {
        'actor_id': actor_id,
        'port_name': port_name,
        'port_dir': 'in',
        'peer_node_id': peer_node_id,
        'peer_actor_id': peer_actor_id,
        'peer_port_name': peer_port_name,
        'peer_port_dir': 'out',
    }
    r = async._post(rt, timeout, async, CONNECT, data)
    return self.check_response(r)

dataset/ETHPy150Open EricssonResearch/calvin-base/calvin/requests/request_handler.py RequestHandler.connect/VarMisuse@73/147 `self`->`async`