File tree Expand file tree Collapse file tree 1 file changed +16
-0
lines changed Expand file tree Collapse file tree 1 file changed +16
-0
lines changed Original file line number Diff line number Diff line change @@ -606,6 +606,14 @@ onmessage = async (event) => {
606606 num_arrow_dataFile_data_recs_processed,
607607 num_arrow_metaFile_data_recs_processed
608608 } )
609+ postMessage (
610+ await errorMsg ( reqID , {
611+ type : 'runWorkerError' ,
612+ code : 'TIMEOUT' ,
613+ message :
614+ 'Server stopped sending data before all records were received. The request may have timed out or the server encountered an error.'
615+ } )
616+ )
609617 //if(num_retries_left === 0) throw new Error('SlideRuleError:The server quit unexpectedly.');
610618 }
611619 logger . debug ( 'Final callback counts' , {
@@ -701,6 +709,14 @@ onmessage = async (event) => {
701709 logger . debug ( 'Finally: file written' , { fileName, offset : arrowDataFileOffset } )
702710 } else {
703711 logger . error ( 'Finally: No arrow Data File data records were processed' )
712+ postMessage (
713+ await errorMsg ( reqID , {
714+ type : 'runWorkerError' ,
715+ code : 'NO_DATA' ,
716+ message :
717+ 'No data was received from the server. The request may have failed, returned empty results, or encountered a server error.'
718+ } )
719+ )
704720 }
705721 await checkDoneProcessing (
706722 reqID ,
You can’t perform that action at this time.
0 commit comments