From 33dd596a5a5308eba5fcdac4926bb107733f0b46 Mon Sep 17 00:00:00 2001 From: dcore94 Date: Thu, 16 Sep 2021 17:14:59 +0200 Subject: [PATCH] fixed report generation --- templates/da_cache_to_shub.json.j2 | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/templates/da_cache_to_shub.json.j2 b/templates/da_cache_to_shub.json.j2 index ba4faee..bb353bd 100644 --- a/templates/da_cache_to_shub.json.j2 +++ b/templates/da_cache_to_shub.json.j2 @@ -170,7 +170,7 @@ "type": "LAMBDA", "inputParameters": { "input" : "${workflow.input.descriptor}", - "output" : "${join_manage_output.output}", + "output" : "${join_parallel_downloads.output}", "scriptExpression": "var k,report={requestid:$.input.request_id,order_number:$.input.order_number,errors:[]},keys=Object.keys($.output).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:Java.to(report,'java.util.Map[]')}" } } @@ -182,7 +182,7 @@ "type": "LAMBDA", "inputParameters": { "input" : "${workflow.input.descriptor}", - "output" : "${join_manage_output.output}", + "output" : "${join_parallel_downloads.output}", "scriptExpression": "var k,report='',keys=Object.keys($.output).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}" } }