Pipeline versioning apply delete

core/api-server/api/graphql/schemas/pipeline-schema.js

@@ -1,94 +1,118 @@
 const { gql } = require('apollo-server');
 
 const pipelineTypeDefs = gql`
-type Cron { enabled: Boolean pattern: String }
-
-type Triggers { cron: Cron ,pipelines: [String]}
-
-type ConcurrentPipelines { amount: Int rejectOnFailure: Boolean }
-
-type Webhooks { progress:String, result:String }
-
-type Streaming { flows:Object, defaultFlow:String }
-
-type Options { batchTolerance: Int
-  ttl: Int
-  progressVerbosityLevel: String
-  concurrentPipelines: ConcurrentPipelines 
-  activeTtl: Int
-  devMode: Boolean
-  devFolder: String
-}
-
-type Metrics { tensorboard: Boolean }
-type Snapshot{
-              name: String
-}
-
-type Sampler{
-  search_space: Object
-}
-
-type HyperParams{
-                name: String
-                suggest: String
-                high: String
-                low: String
-                choices: [String]
-                sampler: Sampler
-}
-type Spec {
-            name: String
-            id: String
-            snapshot: Snapshot
-            description: String
-            mem: String
-            cpu: String
-            objectivePipeline: String
-            numberOfTrials: Int
-            hyperParams: [HyperParams]
-            sampler: Sampler
-  }
-type Retry { policy: String limit: Int }
-
-type PipelineNodes { 
-  nodeName: String
-  algorithmName: String
-  ttl: Int
-  includeInResult: Boolean
-  batchOperation: String
-  metrics: Metrics
-  retry: Retry
-  spec: Spec
-  kind: String
-  stateType: String
-  input: [Object]
- }
-
-
-
-type Pipeline { 
-  modified: Float
-  kind: String
-  name: String
-  description: String
-  priority: Int
-  experimentName: String
-  triggers: Triggers
-  options: Options
-  webhooks: Webhooks
-  streaming: Streaming
-  nodes: [PipelineNodes ]
-  flowInput: Object 
-}
-type Metrics { tensorboard: Boolean }
-
-type AutogeneratedPipelines { list: [Object],pipelinesCount:Int }
-
-extend type Query {
-    pipelines:AutogeneratedPipelines
-}
+  type Cron {
+    enabled: Boolean
+    pattern: String
+  }
+
+  type Triggers {
+    cron: Cron
+    pipelines: [String]
+  }
+
+  type ConcurrentPipelines {
+    amount: Int
+    rejectOnFailure: Boolean
+  }
+
+  type Webhooks {
+    progress: String
+    result: String
+  }
+
+  type Streaming {
+    flows: Object
+    defaultFlow: String
+  }
+
+  type Options {
+    batchTolerance: Int
+    ttl: Int
+    progressVerbosityLevel: String
+    concurrentPipelines: ConcurrentPipelines
+    activeTtl: Int
+    devMode: Boolean
+    devFolder: String
+  }
+
+  type Metrics {
+    tensorboard: Boolean
+  }
+
+  type Snapshot {
+    name: String
+  }
 
+  type Sampler {
+    search_space: Object
+  }
+
+  type HyperParams {
+    name: String
+    suggest: String
+    high: String
+    low: String
+    choices: [String]
+    sampler: Sampler
+  }
+
+  type Spec {
+    name: String
+    id: String
+    snapshot: Snapshot
+    description: String
+    mem: String
+    cpu: String
+    objectivePipeline: String
+    numberOfTrials: Int
+    hyperParams: [HyperParams]
+    sampler: Sampler
+  }
+
+  type Retry {
+    policy: String
+    limit: Int
+  }
+
+  type PipelineNodes {
+    nodeName: String
+    algorithmName: String
+    ttl: Int
+    includeInResult: Boolean
+    batchOperation: String
+    metrics: Metrics
+    retry: Retry
+    spec: Spec
+    kind: String
+    stateType: String
+    input: [Object]
+  }
+
+  type Pipeline {
+    modified: Float
+    kind: String
+    name: String
+    description: String
+    priority: Int
+    experimentName: String
+    triggers: Triggers
+    options: Options
+    webhooks: Webhooks
+    streaming: Streaming
+    nodes: [PipelineNodes]
+    flowInput: Object
+    version: String
+  }
+
+  type AutogeneratedPipelines {
+    list: [Object]
+    pipelinesCount: Int
+  }
+
+  extend type Query {
+    pipelines: AutogeneratedPipelines
+  }
 `;
 
 module.exports = pipelineTypeDefs;

core/api-server/api/rest-api/routes/v1/exec.js

@@ -40,7 +40,7 @@ const routes = (options) => {
         res.json({ jobId, gateways });
     });
     router.post('/getGraphByStreamingFlow', keycloak.getProtect(keycloakRoles.API_VIEW), async (req, res) => {
-        const { nodes, edges } = await Execution.getGraphByStreamingFlow(req.body);
+        const { nodes, edges } = await Execution._getGraphByStreamingFlow(req.body);
         res.json({ nodes, edges });
     });
     router.post('/stop', keycloak.getProtect(keycloakRoles.API_VIEW), async (req, res) => {

core/api-server/api/rest-api/routes/v1/versions.js

@@ -45,6 +45,14 @@ const routes = (options) => {
         const response = await pipelineVersionsService.getVersion(req.params);
         res.json(response);
     });
+    router.post('/pipelines/apply', keycloak.getProtect(keycloakRoles.API_EDIT), async (req, res) => {
+        const response = await pipelineVersionsService.applyVersion(req.body);
+        res.status(HttpStatus.StatusCodes.CREATED).json(response);
+    });
+    router.delete('/pipelines/:name/:version', keycloak.getProtect(keycloakRoles.API_DELETE), async (req, res) => {
+        const response = await pipelineVersionsService.deleteVersion(req.params);
+        res.json(response);
+    });
 
     return router;
 };