from n2vc.n2vc_conn import N2VCConnector
from n2vc.k8s_helm_conn import K8sHelmConnector
from n2vc.k8s_helm3_conn import K8sHelm3Connector
from n2vc.n2vc_conn import N2VCConnector
from n2vc.k8s_helm_conn import K8sHelmConnector
from n2vc.k8s_helm3_conn import K8sHelm3Connector
kubectl_command=self.vca_config.get("kubectlpath"),
helm_command=self.vca_config.get("helmpath"),
fs=self.fs,
kubectl_command=self.vca_config.get("kubectlpath"),
helm_command=self.vca_config.get("helmpath"),
fs=self.fs,
total_timeout: float = None,
config: dict = None,
artifact_path: str = None,
total_timeout: float = None,
config: dict = None,
artifact_path: str = None,
raise N2VCException("Error deploying chart ee: {}".format(e))
async def register_execution_environment(self, namespace: str, credentials: dict, db_dict: dict,
raise N2VCException("Error deploying chart ee: {}".format(e))
async def register_execution_environment(self, namespace: str, credentials: dict, db_dict: dict,
- progress_timeout: float = None, total_timeout: float = None) -> str:
+ progress_timeout: float = None, total_timeout: float = None,
+ *kargs, **kwargs) -> str:
else:
await self._k8sclusterhelm2.uninstall(system_cluster_uuid, helm_id)
self.log.info("ee_id: {} deleted".format(ee_id))
else:
await self._k8sclusterhelm2.uninstall(system_cluster_uuid, helm_id)
self.log.info("ee_id: {} deleted".format(ee_id))
progress_timeout: float = None,
total_timeout: float = None,
config: dict = None,
progress_timeout: float = None,
total_timeout: float = None,
config: dict = None,
@retryer(max_wait_time=_MAX_RETRY_TIME, delay_time=_EE_RETRY_DELAY)
async def _execute_primitive(self, ip_addr, primitive_name, params, db_dict=None):
@retryer(max_wait_time=_MAX_RETRY_TIME, delay_time=_EE_RETRY_DELAY)
async def _execute_primitive(self, ip_addr, primitive_name, params, db_dict=None):
- return await self._execute_primitive_internal(ip_addr, primitive_name, params, db_dict=db_dict)
+ return await self._execute_primitive_internal(ip_addr, primitive_name, params, db_dict=db_dict)
async def _execute_primitive_internal(self, ip_addr, primitive_name, params, db_dict=None):
async def _execute_primitive_internal(self, ip_addr, primitive_name, params, db_dict=None):