feat(graphql): support uploadPipeline mutation (#302)

* feat: add uploadPipeline mutation

* feat: add upload_pipeline method

Author: yannforget

openhexa/graphql/graphql_client/__init__.py

@@ -381,6 +381,7 @@
     UpgradePipelineVersionFromTemplate,
     UpgradePipelineVersionFromTemplateUpgradePipelineVersionFromTemplate,
 )
+from .upload_pipeline import UploadPipeline, UploadPipelineUploadPipeline
 from .workspace import (
     Workspace,
     WorkspaceWorkspace,
@@ -731,7 +732,9 @@
     "UpgradePipelineVersionFromTemplateInput",
     "UpgradePipelineVersionFromTemplateUpgradePipelineVersionFromTemplate",
     "Upload",
+    "UploadPipeline",
     "UploadPipelineInput",
+    "UploadPipelineUploadPipeline",
     "VerifyDeviceError",
     "VerifyDeviceInput",
     "Workspace",

openhexa/graphql/graphql_client/client.py

@@ -68,6 +68,7 @@
     UpdateWebappInput,
     UpdateWorkspaceInput,
     UpgradePipelineVersionFromTemplateInput,
+    UploadPipelineInput,
 )
 from .invite_workspace_member import (
     InviteWorkspaceMember,
@@ -88,6 +89,7 @@
     UpgradePipelineVersionFromTemplate,
     UpgradePipelineVersionFromTemplateUpgradePipelineVersionFromTemplate,
 )
+from .upload_pipeline import UploadPipeline, UploadPipelineUploadPipeline
 from .workspace import Workspace, WorkspaceWorkspace
 from .workspaces import Workspaces, WorkspacesWorkspaces
 
@@ -247,6 +249,26 @@ def create_pipeline(
         data = self.get_data(response)
         return CreatePipeline.model_validate(data).create_pipeline
 
+    def upload_pipeline(
+        self, input: UploadPipelineInput, **kwargs: Any
+    ) -> UploadPipelineUploadPipeline:
+        query = gql(
+            """
+            mutation uploadPipeline($input: UploadPipelineInput!) {
+              uploadPipeline(input: $input) {
+                success
+                errors
+              }
+            }
+            """
+        )
+        variables: Dict[str, object] = {"input": input}
+        response = self.execute(
+            query=query, operation_name="uploadPipeline", variables=variables, **kwargs
+        )
+        data = self.get_data(response)
+        return UploadPipeline.model_validate(data).upload_pipeline
+
     def delete_pipeline(
         self, input: DeletePipelineInput, **kwargs: Any
     ) -> DeletePipelineDeletePipeline:

openhexa/graphql/graphql_client/upload_pipeline.py

@@ -0,0 +1,21 @@
+# Generated by ariadne-codegen
+# Source: openhexa/graphql/queries.graphql
+
+from typing import List
+
+from pydantic import Field
+
+from .base_model import BaseModel
+from .enums import PipelineError
+
+
+class UploadPipeline(BaseModel):
+    upload_pipeline: "UploadPipelineUploadPipeline" = Field(alias="uploadPipeline")
+
+
+class UploadPipelineUploadPipeline(BaseModel):
+    success: bool
+    errors: List[PipelineError]
+
+
+UploadPipeline.model_rebuild()

openhexa/graphql/queries.graphql

@@ -91,6 +91,13 @@ mutation CreatePipeline($input: CreatePipelineInput!) {
   }
 }
 
+mutation uploadPipeline($input: UploadPipelineInput!) {
+    uploadPipeline(input: $input) {
+        success
+        errors
+    }
+}
+
 mutation DeletePipeline($input: DeletePipelineInput!) {
   deletePipeline(input: $input) {
     success