Revision 16b0afe6 kamaki/cli/commands/pithos_cli.py
b/kamaki/cli/commands/pithos_cli.py | ||
---|---|---|
1052 | 1052 |
def _run(self, local_path, remote_path): |
1053 | 1053 |
poolsize = self['poolsize'] |
1054 | 1054 |
if poolsize > 0: |
1055 |
self.client.POOL_SIZE = int(poolsize)
|
|
1055 |
self.client.MAX_THREADS = int(poolsize)
|
|
1056 | 1056 |
params = dict( |
1057 | 1057 |
content_encoding=self['content_encoding'], |
1058 | 1058 |
content_type=self['content_type'], |
... | ... | |
1292 | 1292 |
#outputs = self._outputs(local_path) |
1293 | 1293 |
poolsize = self['poolsize'] |
1294 | 1294 |
if poolsize: |
1295 |
self.client.POOL_SIZE = int(poolsize)
|
|
1295 |
self.client.MAX_THREADS = int(poolsize)
|
|
1296 | 1296 |
progress_bar = None |
1297 | 1297 |
try: |
1298 | 1298 |
for f, rpath in self._outputs(local_path): |
Also available in: Unified diff