File tree Expand file tree Collapse file tree 1 file changed +8
-2
lines changed
packages/core/src/v3/runtime Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Original file line number Diff line number Diff line change 1- import { ConcurrentWaitError } from "../errors.js" ;
1+ import { InternalError } from "../errors.js" ;
2+ import { TaskRunErrorCodes } from "../schemas/common.js" ;
23
34const concurrentWaitErrorMessage =
45 "Parallel waits are not supported, e.g. using Promise.all() around our wait functions." ;
@@ -9,7 +10,12 @@ export function preventMultipleWaits() {
910 return async < T > ( cb : ( ) => Promise < T > ) : Promise < T > => {
1011 if ( isExecutingWait ) {
1112 console . error ( concurrentWaitErrorMessage ) ;
12- throw new ConcurrentWaitError ( concurrentWaitErrorMessage ) ;
13+ throw new InternalError ( {
14+ code : TaskRunErrorCodes . TASK_DID_CONCURRENT_WAIT ,
15+ message : concurrentWaitErrorMessage ,
16+ skipRetrying : true ,
17+ showStackTrace : false ,
18+ } ) ;
1319 }
1420
1521 isExecutingWait = true ;
You can’t perform that action at this time.
0 commit comments