# initialize helm client-only
self.log.debug("Initializing helm client-only...")
command = "{} init --client-only --stable-repo-url {} ".format(
# initialize helm client-only
self.log.debug("Initializing helm client-only...")
command = "{} init --client-only --stable-repo-url {} ".format(
- async def _cluster_init(self, cluster_id: str, namespace: str,
- paths: dict, env: dict):
+ async def _cluster_init(
+ self, cluster_id: str, namespace: str, paths: dict, env: dict
+ ):
"""
Implements the helm version dependent cluster initialization:
For helm2 it initialized tiller environment if needed
"""
Implements the helm version dependent cluster initialization:
For helm2 it initialized tiller environment if needed
)
_, _rc = await self._local_async_exec(
command=command, raise_exception_on_error=True, env=env
)
_, _rc = await self._local_async_exec(
command=command, raise_exception_on_error=True, env=env
for repo in repo_list:
if repo["name"] == "stable" and repo["url"] != self._stable_repo_url:
self.log.debug("Add new stable repo url: {}")
for repo in repo_list:
if repo["name"] == "stable" and repo["url"] != self._stable_repo_url:
self.log.debug("Add new stable repo url: {}")
- await self.repo_remove(cluster_uuid,
- "stable")
- await self.repo_add(cluster_uuid,
- "stable",
- self._stable_repo_url)
+ await self.repo_remove(cluster_uuid, "stable")
+ await self.repo_add(cluster_uuid, "stable", self._stable_repo_url)
- def _get_inspect_command(self, show_command: str, kdu_model: str, repo_str: str,
- version: str):
+ def _get_inspect_command(
+ self, show_command: str, kdu_model: str, repo_str: str, version: str
+ ):
inspect_command = "{} inspect {} {}{} {}".format(
self._helm_command, show_command, kdu_model, repo_str, version
)
inspect_command = "{} inspect {} {}{} {}".format(
self._helm_command, show_command, kdu_model, repo_str, version
)
- command = "{helm} upgrade {atomic} --output yaml {params} {timeout} {name} {model} {ver}"\
- .format(helm=self._helm_command,
- atomic=atomic_str,
- params=params_str,
- timeout=timeout_str,
- name=kdu_instance,
- model=kdu_model,
- ver=version_str
- )
+ command = "{helm} upgrade {atomic} --output yaml {params} {timeout} {name} {model} {ver}".format(
+ helm=self._helm_command,
+ atomic=atomic_str,
+ params=params_str,
+ timeout=timeout_str,
+ name=kdu_instance,
+ model=kdu_model,
+ ver=version_str,
+ )
return command
def _get_rollback_command(self, kdu_instance, namespace, revision) -> str:
return command
def _get_rollback_command(self, kdu_instance, namespace, revision) -> str: