diff --git a/solutions/system_design/sales_rank/sales_rank_mapreduce.py b/solutions/system_design/sales_rank/sales_rank_mapreduce.py index bbe844b4..d9d2eb21 100644 --- a/solutions/system_design/sales_rank/sales_rank_mapreduce.py +++ b/solutions/system_design/sales_rank/sales_rank_mapreduce.py @@ -25,7 +25,7 @@ class SalesRanker(MRJob): if self.within_past_week(timestamp): yield (category, product_id), quantity - def reducer(self, key, value): + def reducer(self, key, values): """Sum values for each key. (foo, p1), 2 @@ -74,4 +74,4 @@ class SalesRanker(MRJob): if __name__ == '__main__': - HitCounts.run() + SalesRanker.run()