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
1717import { findEnvironmentFromRun } from "~/models/runtimeEnvironment.server" ;
1818import { env } from "~/env.server" ;
1919import { getTaskEventStoreTableForRun } from "./taskEventStore.server" ;
20+ import { MetadataTooLargeError } from "~/utils/packets" ;
2021
2122export function registerRunEngineEventBusHandlers ( ) {
2223 engine . eventBus . on ( "runSucceeded" , async ( { time, run } ) => {
@@ -381,17 +382,31 @@ export function registerRunEngineEventBusHandlers() {
381382 try {
382383 await updateMetadataService . call ( run . id , run . metadata , env ) ;
383384 } 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+ }
395410 }
396411 } ) ;
397412
You can’t perform that action at this time.
0 commit comments