@@ -41,14 +41,18 @@ class HTTPAdapterWithConnParams(requests.adapters.HTTPAdapter):
4141 block=self._pool_block, **self._conn_params)
4242
4343
44+connect = settings['outgoing'].get('pool_connections', 100) # Magic number kept from previous code
45+maxsize = settings['outgoing'].get('pool_maxsize', requests.adapters.DEFAULT_POOLSIZE) # Picked from constructor
4446if settings['outgoing'].get('source_ips'):
45− http_adapters = cycle(HTTPAdapterWithConnParams(pool_connections=100, source_address=(source_ip, 0))
47+ http_adapters = cycle(HTTPAdapterWithConnParams(pool_connections=connect, pool_maxsize=maxsize,
48+ source_address=(source_ip, 0))
4649 for source_ip in settings['outgoing']['source_ips'])
47− https_adapters = cycle(HTTPAdapterWithConnParams(pool_connections=100, source_address=(source_ip, 0))
50+ https_adapters = cycle(HTTPAdapterWithConnParams(pool_connections=connect, pool_maxsize=maxsize,
51+ source_address=(source_ip, 0))
4852 for source_ip in settings['outgoing']['source_ips'])
4953else:
50− http_adapters = cycle((HTTPAdapterWithConnParams(pool_connections=100), ))
51− https_adapters = cycle((HTTPAdapterWithConnParams(pool_connections=100), ))
54+ http_adapters = cycle((HTTPAdapterWithConnParams(pool_connections=connect, pool_maxsize=maxsize), ))
55+ https_adapters = cycle((HTTPAdapterWithConnParams(pool_connections=connect, pool_maxsize=maxsize), ))
5256
5357
5458class SessionSinglePool(requests.Session):