Skip to content

Commit 5ab11d6

Browse files
committed
fix to queue_id when not using google jobs
1 parent 3d96188 commit 5ab11d6

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

app.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -182,7 +182,7 @@ def wrapper(*args, **kwargs):
182182

183183
# Extract execution name and short ID for tracking
184184
execution_name = response.get("execution_name", "")
185-
queue_id = execution_name.split('/')[-1] if execution_name else "gcp_job"
185+
gcp_queue_id = execution_name.split('/')[-1] if execution_name else "gcp_job"
186186

187187
# Prepare the response object
188188
response_obj = {
@@ -193,13 +193,13 @@ def wrapper(*args, **kwargs):
193193
"job_name": os.environ.get("GCP_JOB_NAME"),
194194
"location": os.environ.get("GCP_JOB_LOCATION", "us-central1"),
195195
"pid": pid,
196-
"queue_id": queue_id,
196+
"queue_id": gcp_queue_id,
197197
"build_number": BUILD_NUMBER
198198
}
199199
log_job_status(job_id, {
200200
"job_status": "submitted",
201201
"job_id": job_id,
202-
"queue_id": queue_id,
202+
"queue_id": gcp_queue_id,
203203
"process_id": pid,
204204
"response": response_obj
205205
})

0 commit comments

Comments
 (0)