diff --git a/uptime_service_validation/coordinator/server.py b/uptime_service_validation/coordinator/server.py index 56c2c37..0a8a05d 100644 --- a/uptime_service_validation/coordinator/server.py +++ b/uptime_service_validation/coordinator/server.py @@ -82,11 +82,15 @@ def setUpValidatorPods(time_intervals, logging, worker_image, worker_tag): if bool_env_var_set("NO_CHECKS"): logging.info("stateless-verifier will run with --no-checks flag") for index, mini_batch in enumerate(time_intervals): + + # Job name + job_name = f"delegation-verify-{datetime.now(timezone.utc).strftime('%y-%m-%d-%H-%M')}-{index}" + # Define the environment variables env_vars = [ client.V1EnvVar( name="AWS_ROLE_SESSION_NAME", - value=os.environ.get("AWS_ROLE_SESSION_NAME").rstrip("-coordinator"), + value=job_name, ), client.V1EnvVar( name="AWS_REGION", @@ -199,9 +203,6 @@ def setUpValidatorPods(time_intervals, logging, worker_image, worker_tag): volume_mounts=[auth_volume_mount], ) - # Job name - job_name = f"delegation-verify-{datetime.now(timezone.utc).strftime('%y-%m-%d-%H-%M')}-{index}" - # Create the job job = client.V1Job( api_version="batch/v1",