Skip to content
Snippets Groups Projects
Commit d5c95fc1 authored by Charlotte Hausman's avatar Charlotte Hausman
Browse files

UI fixes for follow-on imaging

parent 765cba4c
No related branches found
No related tags found
1 merge request!366UI fixes for follow-on imaging
Pipeline #2283 passed
......@@ -4,7 +4,7 @@
File containing definitions for the other half of the capability side of the Workspaces REST API,
concerning capability requests
"""
import json
from pyramid.httpexceptions import HTTPBadRequest, HTTPNotFound, HTTPPreconditionFailed
from pyramid.request import Request
from pyramid.response import Response
......@@ -126,19 +126,25 @@ def create_follow_on_capability_request(request: Request) -> Response:
followon_type = request.matchdict["followon_type"]
capability_request = request.capability_info.lookup_capability_request(request_id)
parameters = capability_request.current_execution.parameters
parameters = capability_request.current_version.parameters
user_email = parameters["user_email"]
previous_workflow_id = capability_request.current_execution.current_workflow_request_id
metadata = request.workflow_service.retrieve_file_content(
metadata_content = request.workflow_service.retrieve_file_content(
followon_type, previous_workflow_id, "metadata.json"
)
cms_path = metadata["cms_path"]
sdm_id = metadata["fileSetIds"]
metadata = json.loads(metadata_content)
cms_path = metadata["destinationDirectory"] + "/working"
sdm_id = (
metadata["fileSetIds"][0]
if isinstance(metadata["fileSetIds"], list)
else metadata["fileSetIds"]
)
new_capability_request = request.capability_service.create_request(
followon_type, parameters={"cmsPath": cms_path, "sdmId": sdm_id, "user_email": user_email}
followon_type, parameters={"cms_path": cms_path, "sdmId": sdm_id, "user_email": user_email}
)
return Response(json_body=new_capability_request.__json__())
......
......@@ -80,7 +80,10 @@ class WorkflowServiceRESTClient(WorkflowServiceIF):
:return: dict containing file content
"""
requests.get(f"{self.url}/workflow/{name}/requests/{request_id}/files/{filename}")
response = requests.get(
f"{self.url}/workflows/{name}/requests/{request_id}/files/{filename}"
)
return response.content.decode()
def create_workflow_request(
self, workflow: Union[str, WorkflowIF], argument: Dict
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment