Rfaulk has uploaded a new change for review.
https://gerrit.wikimedia.org/r/77678
Change subject: rm. wait_queue; no longer necessary.
......................................................................
rm. wait_queue; no longer necessary.
Change-Id: I64e5431f8b87fc770188676f19861d6bb2f07490
---
M user_metrics/api/engine/request_manager.py
1 file changed, 0 insertions(+), 15 deletions(-)
git pull ssh://gerrit.wikimedia.org:29418/analytics/user-metrics
refs/changes/78/77678/1
diff --git a/user_metrics/api/engine/request_manager.py
b/user_metrics/api/engine/request_manager.py
index bdb4406..37231a4 100644
--- a/user_metrics/api/engine/request_manager.py
+++ b/user_metrics/api/engine/request_manager.py
@@ -128,7 +128,6 @@
# Store executed and pending jobs respectively
job_queue = list()
- wait_queue = list()
# Global job ID number
job_id = 0
@@ -192,20 +191,6 @@
'COHORT = {2} - METRIC = {3}'\
.format(str(job_id), concurrent_jobs,
wait_req.cohort_expr, wait_req.metric))
-
-
- # Add newest job to the queue
- # ---------------------------
-
- if req_item:
-
- # Build the request item
- rm = rebuild_unpacked_request(req_item)
-
- logging.debug(log_name + ' : REQUEST -> WAIT ' \
- '\n\tCOHORT = {0} - METRIC = {1}'
- .format(rm.cohort_expr, rm.metric))
- wait_queue.append(rm)
logging.debug('{0} - FINISHING.'.format(log_name))
--
To view, visit https://gerrit.wikimedia.org/r/77678
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I64e5431f8b87fc770188676f19861d6bb2f07490
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
