Save progress

kpops/cli/main.py

@@ -306,7 +306,6 @@ def deploy(
     verbose: bool = VERBOSE_OPTION,
 ):
     async def deploy_runner(component: PipelineComponent):
-        print("Entre en runner de ", component.name )
         await component.deploy(dry_run)
 
     async def async_deploy():

kpops/component_handlers/helm_wrapper/helm.py

@@ -34,6 +34,8 @@ def __init__(self, helm_config: HelmConfig) -> None:
             msg = f"The supported Helm version is 3.x.x. The current Helm version is {self._version.major}.{self._version.minor}.{self._version.patch}"
             raise RuntimeError(msg)
 
+
+
     def add_repo(
         self,
         repository_name: str,
@@ -71,7 +73,7 @@ def add_repo(
         else:
             self.__execute(["helm", "repo", "update"])
 
-    def upgrade_install(
+    async def upgrade_install(
         self,
         release_name: str,
         chart: str,
@@ -102,7 +104,7 @@ def upgrade_install(
                 command.append("--dry-run")
             return self.__execute(command)
 
-    def uninstall(
+    async def uninstall(
         self,
         namespace: str,
         release_name: str,

kpops/pipeline_generator/pipeline.py

@@ -240,8 +240,6 @@ def __init__(
         self.parse_components(component_list)
         self.components.generate_graph()
         self.validate()
-        print("Este es graph")
-        print(self.components.graph.nodes)
 
     @classmethod
     def load_from_yaml(

test.py

@@ -0,0 +1,21 @@
+import asyncio
+
+
+async def hello():
+    print("Testing")
+
+
+async def long():
+    return "this is long"
+
+
+def otherThing():
+    loop = asyncio.run(long())
+
+
+async def main():
+    await hello()
+    otherThing()
+    await hello()
+
+asyncio.run(main())