in cloud-run-cloud-spanner/locustfile.py [0:0]
def createUser(self):
# id_token = google.oauth2.id_token.fetch_id_token(request, target_audience)
headers = {"Authorization": f"Bearer {id_token}",
"Content-Type": "application/json"}
data = {"username": self.generateUsername(), "email": self.generateEmail()}
with self.client.post("/user", data=json.dumps(data), headers=headers, catch_response=True) as response:
if response.status_code == 401:
self.getIdToken()
raise RescheduleTask()