engineering/un-inception
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix: detect API restart during job polling (502 then 404)

Browse source 
When the API restarts mid-poll, in-memory job state is lost.
Previously this showed a generic "job not found" after silent
retries. Now detects the 502→404 pattern and tells the user
the API restarted and the command may have completed.
This commit is contained in:
russell@unturf.com 2026-02-07 13:07:48 -05:00
parent 4412bfc8af
commit fee81266a7
1 changed files with 13 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

16
clients/c/src/un.c
View file

@ -1106,6 +1106,7 @@ static char* poll_job_status(const UnsandboxCredentials *creds, const char *job_
int poll_count = 0;
int consecutive_errors = 0;
int saw_server_errors = 0;
char *final_response = NULL;
while (1) {
@ -1153,19 +1154,28 @@ static char* poll_job_status(const UnsandboxCredentials *creds, const char *job_
curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &http_code);
if (http_code == 404) {
// Job might not be registered yet (brief race window)
consecutive_errors++;
if (consecutive_errors > 5) {
fprintf(stderr, "Error: job not found\n");
if (saw_server_errors) {
// API restarted (502/503 then 404) — job state lost
fprintf(stderr, "Error: API restarted — job result lost (in-memory job state cleared)\n");
fprintf(stderr, "The command may have completed on the container.\n");
fprintf(stderr, "Job ID: %s\n", job_id);
free(response.data);
break;
}
if (consecutive_errors > 5) {
fprintf(stderr, "Error: job %s not found\n", job_id);
free(response.data);
break;
}
// Job might not be registered yet (brief race window)
free(response.data);
continue;
}
if (http_code >= 500) {
consecutive_errors++;
saw_server_errors = 1;
if (consecutive_errors >= POLL_MAX_CONSECUTIVE_ERRORS) {
fprintf(stderr, "Error: Server errors after %d retries\n", consecutive_errors);
fprintf(stderr, "Job ID: %s — check later with: un jobs --get %s\n", job_id, job_id);