@@ -283,6 +283,7 @@ def prepare_merge(self, datacube, irregular_datacube, datasets, satellite, bands
283
283
# Build the basics of the merge activity
284
284
activity = {}
285
285
activity ['action' ] = 'merge'
286
+ activity ['bucket_name' ] = services .bucket_name
286
287
activity ['datacube' ] = datacube
287
288
activity ['irregular_datacube' ] = irregular_datacube
288
289
activity ['version' ] = version
@@ -295,9 +296,8 @@ def prepare_merge(self, datacube, irregular_datacube, datasets, satellite, bands
295
296
activity ['resx' ] = resx
296
297
activity ['resy' ] = resy
297
298
activity ['srs' ] = crs
298
- activity ['nodata' ] = nodata
299
- activity ['quality_nodata' ] = quality_nodata
300
- activity ['bucket_name' ] = services .bucket_name
299
+ activity ['nodata' ] = int (nodata )
300
+ activity ['quality_nodata' ] = int (quality_nodata )
301
301
activity ['quality_band' ] = quality_band
302
302
activity ['functions' ] = functions
303
303
activity ['force' ] = force
@@ -781,7 +781,7 @@ def next_blend(services, mergeactivity):
781
781
blendactivity = {}
782
782
blendactivity ['action' ] = 'blend'
783
783
for key in ['datasets' , 'satellite' , 'bands' , 'quicklook' , 'srs' , 'functions' , 'bands_ids' ,
784
- 'tileid' , 'start' , 'end' , 'dirname' , 'nodata' , 'bucket_name' , 'quality_band' ,
784
+ 'tileid' , 'start' , 'end' , 'dirname' , 'nodata' , 'bucket_name' , 'quality_band' , 'quality_nodata' ,
785
785
'internal_bands' , 'force' , 'version' , 'datacube' , 'irregular_datacube' , 'mask' ,
786
786
'bands_expressions' , 'indexes_only_regular_cube' , 'empty_file' , 'landsat_harmonization' ]:
787
787
blendactivity [key ] = mergeactivity .get (key , '' )
@@ -1010,6 +1010,8 @@ def blend(self, activity):
1010
1010
resolution = 10
1011
1011
mask_tuples .append ((100. * efficacy / resolution , key ))
1012
1012
1013
+ mask_tuples = sorted (mask_tuples , reverse = True )
1014
+
1013
1015
provenance_merge_map = dict ()
1014
1016
build_provenance = activity .get ('internal_band' ) == PROVENANCE_NAME
1015
1017
build_clear_observation = activity .get ('internal_band' ) == CLEAR_OBSERVATION_NAME
0 commit comments