fixed report generation

This commit is contained in:
dcore94 2021-09-16 18:45:13 +02:00
parent 1394e6570e
commit 5b2c674210
1 changed files with 29 additions and 0 deletions

View File

@ -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='<table><thead><tr><th>Download</th><th>Outcome</th><th>Link</th></tr></thead><tbody>',keys=[];for(var k in $.output) keys.push(k);keys.sort();for(k in keys){var index=keys[k].split('_')[1];report+='<tr><td>'+index+'</td>';var o=$.output[keys[k]];o.endpoint1.error||o.endpoint2.error?report+='<td>'+(o.endpoint1.error||'')+(o.endpoint2.error||'')+'</td>':report+='<td>OK</td>',report+='</tr>'}report+='</tbody></table>';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}"
}
}
}
]
]