@@ -368,11 +368,7 @@ export function SocketProvider({ children, user }: SocketProviderProps) {
368368 eventHandlers . current . workflowReverted ?.( data )
369369 } )
370370
371- const rehydrateWorkflowStores = async (
372- workflowId : string ,
373- workflowState : any ,
374- source : 'copilot' | 'workflow-state'
375- ) => {
371+ const rehydrateWorkflowStores = async ( workflowId : string , workflowState : any ) => {
376372 const [
377373 { useOperationQueueStore } ,
378374 { useWorkflowRegistry } ,
@@ -397,7 +393,7 @@ export function SocketProvider({ children, user }: SocketProviderProps) {
397393 . getState ( )
398394 . operations . some ( ( op : any ) => op . workflowId === workflowId && op . status !== 'confirmed' )
399395 if ( hasPending ) {
400- logger . info ( ` Skipping ${ source } rehydration due to pending operations in queue` )
396+ logger . info ( ' Skipping rehydration due to pending operations in queue' )
401397 return false
402398 }
403399
@@ -426,7 +422,7 @@ export function SocketProvider({ children, user }: SocketProviderProps) {
426422 } ,
427423 } ) )
428424
429- logger . info ( ` Successfully rehydrated stores from ${ source } ` )
425+ logger . info ( ' Successfully rehydrated workflow stores' )
430426 return true
431427 }
432428
@@ -500,7 +496,7 @@ export function SocketProvider({ children, user }: SocketProviderProps) {
500496
501497 if ( workflowData ?. state ) {
502498 try {
503- await rehydrateWorkflowStores ( workflowData . id , workflowData . state , 'workflow-state' )
499+ await rehydrateWorkflowStores ( workflowData . id , workflowData . state )
504500 } catch ( error ) {
505501 logger . error ( 'Error rehydrating workflow state:' , error )
506502 }
0 commit comments