in cloud-run-cloud-spanner/locustfile.py [0:0]
def readUser(self):
# id_token = google.oauth2.id_token.fetch_id_token(request, target_audience)
username = users[random.randint(0, len(users)-1)]['username']
headers = {"Authorization": f"Bearer {id_token}",
"Content-Type": "application/json"}
with self.client.get(f"/user/{username}", headers=headers, catch_response=True) as response:
if response.status_code == 401:
self.getIdToken()
raise RescheduleTask()