@@ -45,9 +45,6 @@ def gcp(repository, revision, report, platform, suite):
4545
4646 logger .info ("Uploaded {} on {}" .format (path , bucket ))
4747
48- # Trigger ingestion on backend
49- gcp_ingest (repository , revision , platform , suite )
50-
5148 return blob
5249
5350
@@ -64,38 +61,6 @@ def gcp_covdir_exists(
6461 return blob .exists ()
6562
6663
67- @tenacity .retry (
68- stop = tenacity .stop_after_attempt (10 ),
69- wait = tenacity .wait_exponential (multiplier = 1 , min = 16 , max = 64 ),
70- reraise = True ,
71- )
72- def gcp_ingest (repository , revision , platform , suite ):
73- """
74- The GCP report ingestion is triggered remotely on a backend
75- by making a simple HTTP request on the /v2/path endpoint
76- By specifying the exact new revision processed, the backend
77- will download automatically the new report.
78- """
79- params = {"repository" : repository , "changeset" : revision }
80- if platform :
81- params ["platform" ] = platform
82- if suite :
83- params ["suite" ] = suite
84- backend_host = secrets [secrets .BACKEND_HOST ]
85- logger .info (
86- "Ingesting report on backend" ,
87- host = backend_host ,
88- repository = repository ,
89- revision = revision ,
90- platform = platform ,
91- suite = suite ,
92- )
93- resp = requests .get ("{}/v2/path" .format (backend_host ), params = params )
94- resp .raise_for_status ()
95- logger .info ("Successfully ingested report on backend !" )
96- return resp
97-
98-
9964def gcp_latest (repository ):
10065 """
10166 List the latest reports ingested on the backend
0 commit comments