Skip to content
Snippets Groups Projects
Commit 25bc3d10 authored by Geoff Cureton's avatar Geoff Cureton
Browse files

Added a contraint to the Fusion quicklooks that aborts the computation if less...

Added a contraint to the Fusion quicklooks that aborts the computation if less than 95% of the input data is available.
parent 32e7fe59
No related branches found
No related tags found
No related merge requests found
...@@ -823,6 +823,9 @@ class FUSION_MATLAB_QL(Computation): ...@@ -823,6 +823,9 @@ class FUSION_MATLAB_QL(Computation):
if vgeom == []: if vgeom == []:
raise WorkflowNotReady('Missing {} inputs for version {} and interval {}'.format( raise WorkflowNotReady('Missing {} inputs for version {} and interval {}'.format(
input_name, version, interval)) input_name, version, interval))
if len(vgeom) < 228:
raise WorkflowNotReady('Number of available {} inputs is < 228, for version {} and interval {}, aborting...'.format(
input_name, version, interval))
for idx, geo_file in enumerate(vgeom): for idx, geo_file in enumerate(vgeom):
LOG.debug('V03MOD granule {}: {} -> {}'.format(idx, geo_file.begin_time, geo_file.end_time)) LOG.debug('V03MOD granule {}: {} -> {}'.format(idx, geo_file.begin_time, geo_file.end_time))
task.input('geo_{}'.format(idx), geo_file) task.input('geo_{}'.format(idx), geo_file)
...@@ -838,6 +841,9 @@ class FUSION_MATLAB_QL(Computation): ...@@ -838,6 +841,9 @@ class FUSION_MATLAB_QL(Computation):
if vl1b == []: if vl1b == []:
raise WorkflowNotReady('Missing {} inputs for version {} and interval {}'.format( raise WorkflowNotReady('Missing {} inputs for version {} and interval {}'.format(
input_name, version, interval)) input_name, version, interval))
if len(vl1b) < 228:
raise WorkflowNotReady('Number of available {} inputs is < 228, for version {} and interval {}, aborting...'.format(
input_name, version, interval))
for idx, l1b_file in enumerate(vl1b): for idx, l1b_file in enumerate(vl1b):
LOG.debug('V02FSN granule {}: {} -> {}'.format(idx, l1b_file.begin_time, l1b_file.end_time)) LOG.debug('V02FSN granule {}: {} -> {}'.format(idx, l1b_file.begin_time, l1b_file.end_time))
task.input('l1b_{}'.format(idx), l1b_file) task.input('l1b_{}'.format(idx), l1b_file)
......
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