File tree Expand file tree Collapse file tree 1 file changed +26
-11
lines changed Expand file tree Collapse file tree 1 file changed +26
-11
lines changed Original file line number Diff line number Diff line change @@ -17,6 +17,7 @@ import { updateMetadataService } from "~/services/metadata/updateMetadataInstanc
17
17
import { findEnvironmentFromRun } from "~/models/runtimeEnvironment.server" ;
18
18
import { env } from "~/env.server" ;
19
19
import { getTaskEventStoreTableForRun } from "./taskEventStore.server" ;
20
+ import { MetadataTooLargeError } from "~/utils/packets" ;
20
21
21
22
export function registerRunEngineEventBusHandlers ( ) {
22
23
engine . eventBus . on ( "runSucceeded" , async ( { time, run } ) => {
@@ -381,17 +382,31 @@ export function registerRunEngineEventBusHandlers() {
381
382
try {
382
383
await updateMetadataService . call ( run . id , run . metadata , env ) ;
383
384
} catch ( e ) {
384
- logger . error ( "[runMetadataUpdated] Failed to update metadata" , {
385
- taskRun : run . id ,
386
- error :
387
- e instanceof Error
388
- ? {
389
- name : e . name ,
390
- message : e . message ,
391
- stack : e . stack ,
392
- }
393
- : e ,
394
- } ) ;
385
+ if ( e instanceof MetadataTooLargeError ) {
386
+ logger . warn ( "[runMetadataUpdated] Failed to update metadata, too large" , {
387
+ taskRun : run . id ,
388
+ error :
389
+ e instanceof Error
390
+ ? {
391
+ name : e . name ,
392
+ message : e . message ,
393
+ stack : e . stack ,
394
+ }
395
+ : e ,
396
+ } ) ;
397
+ } else {
398
+ logger . error ( "[runMetadataUpdated] Failed to update metadata" , {
399
+ taskRun : run . id ,
400
+ error :
401
+ e instanceof Error
402
+ ? {
403
+ name : e . name ,
404
+ message : e . message ,
405
+ stack : e . stack ,
406
+ }
407
+ : e ,
408
+ } ) ;
409
+ }
395
410
}
396
411
} ) ;
397
412
You can’t perform that action at this time.
0 commit comments