ssh_options = [] # type: List[str]
# ssh_config
- ssh_config_fname = self.ssh_config_file # type: ignore
+ ssh_config_fname = self.ssh_config_file
ssh_config = self.get_store("ssh_config")
if ssh_config is not None or ssh_config_fname is None:
if not ssh_config:
self._ssh_options = None
self.log.info('ssh_options %s' % ssh_options)
- if self.mode == 'root': # type: ignore
+ if self.mode == 'root':
self.ssh_user = 'root'
- elif self.mode == 'cephadm-package': # type: ignore
+ elif self.mode == 'cephadm-package':
self.ssh_user = 'cephadm'
@staticmethod
final_args += ['--fsid', self._cluster_fsid]
final_args += args
- if self.mode == 'root': # type: ignore
+ if self.mode == 'root':
self.log.debug('args: %s' % (' '.join(final_args)))
self.log.debug('stdin: %s' % stdin)
script = 'injected_argv = ' + json.dumps(final_args) + '\n'
if error_ok:
return '', str(e), 1
raise
- elif self.mode == 'cephadm-package': # type: ignore
+ elif self.mode == 'cephadm-package':
try:
out, err, code = remoto.process.check(
conn,
keys = [node_name]
for host, host_info in self.service_cache.items_filtered(keys):
hosts.append(host)
- if host_info.outdated(self.service_cache_timeout) or refresh: # type: ignore
+ if host_info.outdated(self.service_cache_timeout) or refresh:
self.log.info("refreshing stale services for '{}'".format(host))
wait_for_args.append((host,))
else:
def _get_inventory(host, host_info):
# type: (str, orchestrator.OutdatableData) -> orchestrator.InventoryNode
- if host_info.outdated(self.inventory_cache_timeout) or refresh: # type: ignore
+ if host_info.outdated(self.inventory_cache_timeout) or refresh:
self.log.info("refresh stale inventory for '{}'".format(host))
out, err, code = self._run_cephadm(
host, 'osd',
def upgrade_check(self, image, version):
if version:
- target_name = self.container_image_base + ':v' + version # type: ignore
+ target_name = self.container_image_base + ':v' + version
elif image:
target_name = image
else:
def upgrade_start(self, image, version):
if version:
- target_name = self.container_image_base + ':v' + version # type: ignore
+ target_name = self.container_image_base + ':v' + version
elif image:
target_name = image
else: