diff --git a/source/flo/__init__.py b/source/flo/__init__.py index 0a48231a89eebd2fb1626de00b2a7583fdbd3584..6c4d6f1c433c8a3204affa0f23b4ff370def0cf7 100644 --- a/source/flo/__init__.py +++ b/source/flo/__init__.py @@ -823,6 +823,9 @@ class FUSION_MATLAB_QL(Computation): if vgeom == []: raise WorkflowNotReady('Missing {} inputs for version {} and interval {}'.format( 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): LOG.debug('V03MOD granule {}: {} -> {}'.format(idx, geo_file.begin_time, geo_file.end_time)) task.input('geo_{}'.format(idx), geo_file) @@ -838,6 +841,9 @@ class FUSION_MATLAB_QL(Computation): if vl1b == []: raise WorkflowNotReady('Missing {} inputs for version {} and interval {}'.format( 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): LOG.debug('V02FSN granule {}: {} -> {}'.format(idx, l1b_file.begin_time, l1b_file.end_time)) task.input('l1b_{}'.format(idx), l1b_file)