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'