Rfaulk has uploaded a new change for review.
https://gerrit.wikimedia.org/r/81189
Change subject: add - run method for AggregatorStatOp.
......................................................................
add - run method for AggregatorStatOp.
Change-Id: I031af4aaa42cb075fb1024c038f1e0be77384877
---
M user_metrics/etl/aggregator.py
1 file changed, 9 insertions(+), 1 deletion(-)
git pull ssh://gerrit.wikimedia.org:29418/analytics/user-metrics
refs/changes/89/81189/1
diff --git a/user_metrics/etl/aggregator.py b/user_metrics/etl/aggregator.py
index e512e59..5a663a3 100644
--- a/user_metrics/etl/aggregator.py
+++ b/user_metrics/etl/aggregator.py
@@ -403,4 +403,12 @@
super(AggregatorStatOp, self).data_etl(data)
def post_process(self, data):
- super(AggregatorStatOp, self).post_process(data)
\ No newline at end of file
+ super(AggregatorStatOp, self).post_process(data)
+
+ def run(self, data):
+ """
+ Pass data through aggregate method
+ """
+ for item in self._agg_items:
+ setattr(self, item[0], item[2]([elem[item[1]] for elem in data]))
+ return self
\ No newline at end of file
--
To view, visit https://gerrit.wikimedia.org/r/81189
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I031af4aaa42cb075fb1024c038f1e0be77384877
Gerrit-PatchSet: 1
Gerrit-Project: analytics/user-metrics
Gerrit-Branch: master
Gerrit-Owner: Rfaulk <[email protected]>
_______________________________________________
MediaWiki-commits mailing list
[email protected]
https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits
