You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by kl...@apache.org on 2019/06/11 22:14:14 UTC
[geode] branch develop updated: Revert "GEODE-6852: updated script
due to SSEClient change"
This is an automated email from the ASF dual-hosted git repository.
klund pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/develop by this push:
new 02c133b Revert "GEODE-6852: updated script due to SSEClient change"
02c133b is described below
commit 02c133b7ceb62a1d8fff7488559494b1ef41f600
Author: mhansonp <mh...@pivotal.io>
AuthorDate: Tue Jun 11 15:09:57 2019 -0700
Revert "GEODE-6852: updated script due to SSEClient change"
This reverts commit 85702e55cfa0beff8977f7e036f64cad01b108c1.
---
ci/bin/concourse_job_performance.py | 9 ++++-----
1 file changed, 4 insertions(+), 5 deletions(-)
diff --git a/ci/bin/concourse_job_performance.py b/ci/bin/concourse_job_performance.py
index d3b85ab..0a980b1 100755
--- a/ci/bin/concourse_job_performance.py
+++ b/ci/bin/concourse_job_performance.py
@@ -99,7 +99,7 @@ def examine_build(authorization_cookie, build, url) -> List[SingleFailure]:
event_response = get_event_response(authorization_cookie, build, session, url)
logging.debug("Event Status is {}".format(event_response.status_code))
- build_status, event_output = assess_event_response(event_response, authorization_cookie)
+ build_status, event_output = assess_event_response(event_response)
this_build_failures = assess_event_output_for_failure(build, event_output)
logging.debug("Results: Job status is {}".format(build_status))
@@ -119,13 +119,12 @@ def assess_event_output_for_failure(build, event_output) -> List[SingleFailure]:
return all_failures
-def assess_event_response(event_response, authorization_cookie):
+def assess_event_response(event_response):
event_outputs = []
build_status = 'unknown'
+ event_client = sseclient.SSEClient(event_response)
- event_client = sseclient.SSEClient(event_response.url, cookies=authorization_cookie)
-
- for event in event_client:
+ for event in event_client.events():
event_json = json.loads(event.data if event.data else "{}")
build_status = (event_json['data']['status']
if event_json.get('event', 'not-a-status-event') == 'status'