fix: HEXA-1389 make functional type and tags optional (#324)

* make functional type and tags optional

* fix: add tags to create pipeline

Author: Nazar F

openhexa/cli/api.py

@@ -290,10 +290,22 @@ def get_pipeline_from_code(pipeline_code: str) -> dict[str, typing.Any]:
     return data["pipelineByCode"]
 
 
-def create_pipeline(pipeline_name: str, functional_type: str = None):
+def create_pipeline(pipeline_name: str, functional_type: str = None, tags: list[str] = None):
     """Create a pipeline using the API."""
     if settings.current_workspace is None:
         raise NoActiveWorkspaceError
+
+    input_data = {
+        "workspaceSlug": settings.current_workspace,
+        "name": pipeline_name,
+    }
+
+    if functional_type is not None:
+        input_data["functionalType"] = functional_type
+
+    if tags:
+        input_data["tags"] = tags
+
     data = graphql(
         """
     mutation createPipeline($input: CreatePipelineInput!) {
@@ -308,13 +320,7 @@ def create_pipeline(pipeline_name: str, functional_type: str = None):
         }
     }
     """,
-        {
-            "input": {
-                "workspaceSlug": settings.current_workspace,
-                "name": pipeline_name,
-                "functionalType": functional_type,
-            }
-        },
+        {"input": input_data},
     )
 
     if not data["createPipeline"]["success"]:
@@ -625,6 +631,24 @@ def upload_pipeline(
         zip_file.seek(0)
 
     base64_content = base64.b64encode(zip_file.read()).decode("ascii")
+
+    input_data = {
+        "workspaceSlug": settings.current_workspace,
+        "code": target_pipeline_code,
+        "name": name,
+        "description": description,
+        "externalLink": link,
+        "zipfile": base64_content,
+        "parameters": [p.to_dict() for p in pipeline.parameters],
+        "timeout": pipeline.timeout,
+    }
+
+    if functional_type or pipeline.functional_type:
+        input_data["functionalType"] = functional_type or pipeline.functional_type
+
+    if tags:
+        input_data["tags"] = tags
+
     data = graphql(
         """
             mutation uploadPipeline($input: UploadPipelineInput!) {
@@ -651,20 +675,7 @@ def upload_pipeline(
                 }
             }
         """,
-        {
-            "input": {
-                "workspaceSlug": settings.current_workspace,
-                "code": target_pipeline_code,
-                "name": name,
-                "description": description,
-                "externalLink": link,
-                "zipfile": base64_content,
-                "parameters": [p.to_dict() for p in pipeline.parameters],
-                "timeout": pipeline.timeout,
-                "functionalType": functional_type or pipeline.functional_type,
-                "tags": tags,
-            }
-        },
+        {"input": input_data},
     )
 
     if not data["uploadPipeline"]["success"]:

openhexa/cli/cli.py

@@ -459,10 +459,12 @@ def pipelines_push(
             )
             click.confirm(confirmation_message, default=True, abort=True)
 
-        selected_pipeline = selected_pipeline or create_pipeline(pipeline.name, functional_type=functional_type)
+        normalized_tags = [normalize_tag(t) for t in tag] if tag else []
+        selected_pipeline = selected_pipeline or create_pipeline(
+            pipeline.name, functional_type=functional_type, tags=normalized_tags
+        )
         uploaded_pipeline_version = None
         try:
-            normalized_tags = [normalize_tag(t) for t in tag] if tag else []
             uploaded_pipeline_version = upload_pipeline(
                 selected_pipeline["code"],
                 path,