@@ -672,16 +672,18 @@ func (w *workflowRegistry) syncUsingReconciliationStrategy(ctx context.Context,
672672 w .lggr .Debug ("shutting down readRegistryStateLoop" )
673673 return
674674 case <- ticker :
675- workflowMetadata , _ , err := w .getWorkflowMetadata (ctx , don , reader )
675+ workflowMetadata , head , err := w .getWorkflowMetadata (ctx , don , reader )
676676 if err != nil {
677677 w .lggr .Errorw ("failed to get registry state" , "err" , err )
678678 continue
679679 }
680+ w .lggr .Debugw ("preparing events to reconcile" , "numWorkflowMetadata" , len (workflowMetadata ), "blockHeight" , head .Height , "numPendingEvents" , len (pendingEvents ))
680681 events , err := w .generateReconciliationEvents (ctx , pendingEvents , workflowMetadata , don .ID )
681682 if err != nil {
682683 w .lggr .Errorw ("failed to generate reconciliation events" , "err" , err )
683684 continue
684685 }
686+ w .lggr .Debugw ("generated events to reconcile" , "num" , len (events ))
685687
686688 pendingEvents = map [string ]* reconciliationEvent {}
687689
@@ -715,7 +717,7 @@ func (w *workflowRegistry) syncUsingReconciliationStrategy(ctx context.Context,
715717 }
716718 }
717719
718- w .lggr .Debugw ("generated events to reconcile" , "num" , len ( events ) , "report" , reconcileReport )
720+ w .lggr .Debugw ("reconciled events" , "report" , reconcileReport )
719721 }
720722 }
721723}
0 commit comments