Rfaulk has uploaded a new change for review.
https://gerrit.wikimedia.org/r/77685
Change subject: mod. use pack_response_for_broker to add responses to broker.
......................................................................
mod. use pack_response_for_broker to add responses to broker.
Change-Id: I1dec14db110467be0576cfa767be10c00c878529
---
M user_metrics/api/engine/request_manager.py
1 file changed, 3 insertions(+), 1 deletion(-)
git pull ssh://gerrit.wikimedia.org:29418/analytics/user-metrics
refs/changes/85/77685/1
diff --git a/user_metrics/api/engine/request_manager.py
b/user_metrics/api/engine/request_manager.py
index 36005ce..64fc2ae 100644
--- a/user_metrics/api/engine/request_manager.py
+++ b/user_metrics/api/engine/request_manager.py
@@ -85,6 +85,7 @@
from user_metrics.api import MetricsAPIError, error_codes, query_mod, \
REQUEST_BROKER_TARGET, umapi_broker_context,\
RESPONSE_BROKER_TARGET, PROCESS_BROKER_TARGET
+from user_metrics.api.engine import pack_response_for_broker
from user_metrics.api.engine.data import get_users
from user_metrics.api.engine.request_meta import build_request_obj
from user_metrics.metrics.users import MediaWikiUser
@@ -183,7 +184,8 @@
# Add to response target
umapi_broker_context.add(RESPONSE_BROKER_TARGET, url_hash,
- str(''.join([job_item.request, '--',
data])))
+ pack_response_for_broker(
+ job_item.request, data))
del job_queue[job_queue.index(job_item)]
concurrent_jobs -= 1
--
To view, visit https://gerrit.wikimedia.org/r/77685
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I1dec14db110467be0576cfa767be10c00c878529
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
