Progress statistics not properly updated when running homogenization pipeline via Flink.
The pure-python implementation of the GMS homogenization mappers updates the progress statistics (number of scenes at each processing level) within a decorator that wraps the actual mapper function (see here). The decorator is implemented within the exception_handler module (here).
The decorator updates the 'statistics' column of the pgSQL-database each time a scene changes its processing level:
When a job is started via Flink, currently the progress statistics are not updated. This should be revised.
Edited by Daniel Scheffler