Revision f5ff79d9
| b/kamaki/cli/__init__.py | ||
|---|---|---|
| 307 | 307 |
else: |
| 308 | 308 |
auth_base = AuthCachedClient( |
| 309 | 309 |
auth_args['url'], auth_args['token']) |
| 310 |
from kamaki.cli.commands import _command_init |
|
| 311 |
fake_cmd = _command_init(arguments) |
|
| 312 |
fake_cmd.client = auth_base |
|
| 313 |
fake_cmd._set_log_params() |
|
| 314 |
fake_cmd._update_max_threads() |
|
| 310 | 315 |
auth_base.authenticate(token) |
| 311 | 316 |
except ClientError as ce: |
| 312 | 317 |
if ce.status in (401, ): |
| b/kamaki/cli/commands/__init__.py | ||
|---|---|---|
| 134 | 134 |
def _update_max_threads(self): |
| 135 | 135 |
if getattr(self, 'client', None): |
| 136 | 136 |
max_threads = int(self['config'].get_global('max_threads'))
|
| 137 |
assert max_threads > 0 |
|
| 137 |
assert max_threads > 0, 'invalid max_threads config option'
|
|
| 138 | 138 |
self.client.MAX_THREADS = max_threads |
| 139 | 139 |
|
| 140 | 140 |
def _safe_progress_bar(self, msg, arg='progress_bar'): |
| b/kamaki/cli/commands/astakos.py | ||
|---|---|---|
| 60 | 60 |
if getattr(self, 'cloud', False): |
| 61 | 61 |
base_url = self._custom_url('astakos')
|
| 62 | 62 |
if base_url: |
| 63 |
token = self._custom_token('astakos')\
|
|
| 64 |
or self.config.get_cloud(self.cloud, 'token') |
|
| 63 |
token = self._custom_token( |
|
| 64 |
'astakos') or self.config.get_cloud(self.cloud, 'token')
|
|
| 65 | 65 |
token = token.split()[0] if ' ' in token else token |
| 66 | 66 |
self.client = AstakosClient(base_url=base_url, token=token) |
| 67 | 67 |
return |
Also available in: Unified diff