diff --git a/templates/da_cache_to_shub.json.j2 b/templates/da_cache_to_shub.json.j2 index 9160209..48abe98 100644 --- a/templates/da_cache_to_shub.json.j2 +++ b/templates/da_cache_to_shub.json.j2 @@ -173,6 +173,18 @@ "output" : "${join_parallel_downloads.output}", "scriptExpression": "var k,report={requestid:$.input.request_id,order_number:$.input.order_number,errors:[]},keys=[];for(var k in $.output) keys.push(k);keys.sort();for(k in keys){var index=keys[k].split('_')[1],o=$.output[keys[k]];o.endpoint1.error&&report.errors.push({url:$.input.downloads[index].url,number:index,error_number:1002,error_message:o.endpoint1.error}),o.endpoint2.error&&report.errors.push({url:$.input.descriptor.downloads[index].url,number:index,error_number:9999,error_message:o.endpoint2.error})};return {report:report}" } + }, + { + "name" : "http", + "taskReferenceName" : "send_json_report", + "type" : "HTTP", + "inputParameters" : { + "http_request": { + "uri" : "${workflow.input.callback.url}", + "method" : "POST", + "body" : "${build_json_report.output.result.report}" + } + } } ], [ @@ -185,6 +197,23 @@ "output" : "${join_parallel_downloads.output}", "scriptExpression": "var k,report='',keys=[];for(var k in $.output) keys.push(k);keys.sort();for(k in keys){var index=keys[k].split('_')[1];report+='';var o=$.output[keys[k]];o.endpoint1.error||o.endpoint2.error?report+='':report+='',report+=''}report+='
DownloadOutcomeLink
'+index+''+(o.endpoint1.error||'')+(o.endpoint2.error||'')+'OK
';return { report : report}" } + }, + { + "name" : "pymail", + "taskReferenceName" : "send_email_report", + "type" : "SIMPLE", + "inputParameters" : { + "from" : "bluecloud@d4science.org", + "to" : "${workflow.input.callback.email}", + "text" : "Dear user,\n your request with id {v1} related to order {v2} number {v3} has completed with the following outcome:\n\n {v4}", + "subject" : "Oucome of Bluecloud DA cache download {v1}", + "extra_vars":{ + "v1" : "${workflow.input.descriptor.request_id}", + "v2" : "${workflow.input.descriptor.order_name}", + "v3" : "${workflow.input.descriptor.order_number}", + "v4" : "${build_email_report.output.result.report}" + } + } } ] ]