Rfaulk has uploaded a new change for review.
https://gerrit.wikimedia.org/r/78474
Change subject: fix. handling of response format and setting data.
......................................................................
fix. handling of response format and setting data.
Change-Id: I3081a8033f8304ffc75311678fa717b01a6bfb0c
---
M user_metrics/api/engine/response_handler.py
1 file changed, 7 insertions(+), 10 deletions(-)
git pull ssh://gerrit.wikimedia.org:29418/analytics/user-metrics
refs/changes/74/78474/1
diff --git a/user_metrics/api/engine/response_handler.py
b/user_metrics/api/engine/response_handler.py
index 1afe605..b99cd17 100644
--- a/user_metrics/api/engine/response_handler.py
+++ b/user_metrics/api/engine/response_handler.py
@@ -10,8 +10,9 @@
from user_metrics.api import RESPONSE_BROKER_TARGET, umapi_broker_context
from user_metrics.config import logging
-from user_metrics.api.engine.request_meta import rebuild_unpacked_request
-from user_metrics.api.engine.data import set_data, build_key_signature
+from user_metrics.api.engine import unpack_response_for_broker
+from user_metrics.api.engine.request_meta import build_request_obj
+from user_metrics.api.engine.data import set_data
import time
@@ -34,22 +35,18 @@
time.sleep(RESPONSE_TIMEOUT)
- # Read request from the broker target
+ # Handle any responses as they enter the queue
logging.debug(log_name + ' - POLLING RESPONSES...')
res_item = umapi_broker_context.pop(RESPONSE_BROKER_TARGET)
if not res_item:
continue
- request_meta = rebuild_unpacked_request(res_item)
- key_sig = build_key_signature(request_meta, hash_result=True)
+ req, data = unpack_response_for_broker(res_item)
+ request_meta = build_request_obj(req)
# Add result to cache once completed
- # TODO - umapi_broker_context.add(target, key_sig, res_item)
-
logging.debug(log_name + ' - Setting data for {0}'.format(
str(request_meta)))
- set_data(stream, request_meta)
-
-
+ set_data(data, request_meta)
logging.debug(log_name + ' - SHUTTING DOWN...')
--
To view, visit https://gerrit.wikimedia.org/r/78474
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I3081a8033f8304ffc75311678fa717b01a6bfb0c
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
