properties:
Exception:
type: "string"
-
- /pipelines/{pipe_name}/upload:
+ /pipelines/{pipeline_name}/upload:
post:
tags:
- Pipeline
summary: "Upload pipeline"
description: "Uploads a pipeline file to the server."
parameters:
- - name: "pipe_name"
+ - name: "pipeline_name"
in: "path"
required: true
type: "string"
properties:
Exception:
type: "string"
-
/pipelines/{pipeline_name}/versions:
get:
tags:
200:
description: "Successful response with pipeline versions"
schema:
- type: "object"
- properties:
- versions_list:
- type: "array"
- items:
- type: "string"
+ type: "array"
+ items:
+ type: "string"
500:
description: "Internal server error"
schema:
properties:
Exception:
type: "string"
-
/pipelines:
get:
tags:
schema:
type: "object"
properties:
- pipeline_names:
+ pipelines:
type: "array"
items:
- type: "string"
+ $ref: '#/definitions/PipelineInfo'
+ total_size:
+ type: "integer"
500:
description: "Internal server error"
schema:
properties:
Exception:
type: "string"
-
- /experiments:
+ /pipelines/{pipeline_name}:
+ get:
+ tags:
+ - Pipeline
+ summary: "Get pipeline details corresponding to pipeline_name"
+ description: "Get pipeline details corresponding to pipeline_name"
+ parameters:
+ - name: "pipeline_name"
+ in: "path"
+ required: true
+ type: "string"
+ description: "Name of the pipeline"
+ responses:
+ 200:
+ description: "Detail of pipeline_names: corresponding to pipeline_name"
+ schema:
+ $ref: '#/definitions/PipelineInfo'
+ 404:
+ description: "Pipeline with given pipeline_name not found"
+ schema:
+ type: "object"
+ properties:
+ error:
+ type: "string"
+ 500:
+ description: "Internal server error"
+ schema:
+ type: "object"
+ properties:
+ error:
+ type: "string"
+ /pipelines/experiments:
get:
+ tags:
+ - Pipeline
summary: "Get all experiment names"
description: "Fetches all the names of experiments available."
responses:
200:
description: "Successful response with all experiment names"
schema:
- type: "object"
- properties:
- experiment_names:
- type: "array"
- items:
- type: "string"
+ type: "array"
+ items:
+ type: "string"
500:
description: "Internal server error"
schema:
type: "integer"
title:
type: "string"
-
/featureGroup:
delete:
tags:
description: Optional DME port
source_name:
type: string
- description: Optional name of the data source
\ No newline at end of file
+ description: Optional name of the data source
+ PipelineInfo:
+ type: "object"
+ properties:
+ pipeline_info:
+ type: object
+ properties:
+ created_at:
+ type: string
+ format: date-time
+ description: Timestamp when the pipeline was created
+ description:
+ type: string
+ display_name:
+ type: string
+ pipeline_id:
+ type: string
+ format: uuid
LOGGER.error(f"Unexpected error in get_pipeline_info_by_name: {str(err)}")
return jsonify({"error": "An unexpected error occurred"}), status.HTTP_500_INTERNAL_SERVER_ERROR
-
@pipeline_controller.route("/pipelines/<pipeline_name>/versions", methods=['GET'])
def get_versions_for_pipeline(pipeline_name):
"""
Returns:
json:
- versions_list : list
- list containing all versions(as str)
+ list containing all versions(as str)
status code:
HTTP status code 200
LOGGER.error(str(err))
return jsonify({"Exception": str(err)}), status.HTTP_500_INTERNAL_SERVER_ERROR
-
@pipeline_controller.route('/pipelines', methods=['GET'])
def get_pipelines():
"""
except Exception as err:
LOGGER.error(str(err))
return jsonify({"Exception": str(err)}, status.HTTP_500_INTERNAL_SERVER_ERROR)
-
+
@pipeline_controller.route("/pipelines/<pipeline_name>/upload", methods=['POST'])
def upload_pipeline(pipeline_name):
"""
except Exception as err:
return jsonify({'result': "Error in uploading Pipeline| Error : " + str(err)}), status.HTTP_500_INTERNAL_SERVER_ERROR
-
@pipeline_controller.route("/pipelines/experiments", methods=['GET'])
def get_all_experiment_names():
"""