diff --git a/csdr/cli_products.py b/csdr/cli_products.py index cfa94c5..701dd9b 100644 --- a/csdr/cli_products.py +++ b/csdr/cli_products.py @@ -486,14 +486,14 @@ def consolidate_product( # Each geometry is processed in its own pod, so we record a single # summary step here where the count is known. write_step( - label=f"Process {len(all_data)} geometr{'ies' if len(all_data) != 1 else 'y'} for {len(years)} year{'s' if len(years) != 1 else ''} to compute indicators", + label=f"Process {len(all_data) / len(years)} geometr{'ies' if len(all_data) != 1 else 'y'} for {len(years)} year{'s' if len(years) != 1 else ''} to compute indicators", inputs={ "geometry_provenance_url": geometry_provenance_url, "dataset_provenance_url": dataset_provenance_url, "indicator_name": indicator_name, "years": years, }, - outputs={"geometries_processed": len(all_data)}, + outputs={"geometries_processed": len(all_data) / len(years)}, source_function=process_geometry, command=process_geometry_command, )