test another logic

Author: timl3136

internal/internal_event_handlers.go

@@ -940,10 +940,10 @@ func (weh *workflowExecutionEventHandlerImpl) ProcessEvent(
 		return err
 	}
 
-	//historySizeErr := weh.estimateHistorySize(event)
-	//if historySizeErr != nil {
-	//	weh.logger.Error("Failed to estimate history size", zap.Error(historySizeErr))
-	//}
+	historySizeErr := weh.estimateHistorySize(event)
+	if historySizeErr != nil {
+		weh.logger.Error("Failed to estimate history size", zap.Error(historySizeErr))
+	}
 
 	// When replaying histories to get stack trace or current state the last event might be not
 	// decision started. So always call OnDecisionTaskStarted on the last event.
@@ -1487,5 +1487,6 @@ func (weh *workflowExecutionEventHandlerImpl) estimateHistorySize(event *m.Histo
 		return fmt.Errorf("unknown event type")
 	}
 	weh.workflowInfo.TotalHistoryBytes += int64(sum)
+	weh.logger.Info("EstimateHistorySize", zap.Int("historyBytes", sum), zap.Int64("totalHistoryBytes", weh.workflowInfo.TotalHistoryBytes))
 	return nil
 }

internal/internal_task_handlers.go

@@ -372,10 +372,10 @@ OrderEvents:
 	eh.currentIndex = 0
 
 	// estimate history size for nextEvents and markers
-	historySizeEstimation += eh.estimateHistorySize(nextEvents)
-	historySizeEstimation += eh.estimateHistorySize(markers)
-
-	eh.eventsHandler.logger.Info(fmt.Sprintf("Returning historySizeEstimation not zero of %d", historySizeEstimation))
+	//historySizeEstimation += eh.estimateHistorySize(nextEvents)
+	//historySizeEstimation += eh.estimateHistorySize(markers)
+	//
+	//eh.eventsHandler.logger.Info(fmt.Sprintf("Returning historySizeEstimation not zero of %d", historySizeEstimation))
 
 	return nextEvents, markers, historySizeEstimation, nil
 }
@@ -988,7 +988,7 @@ func (w *workflowExecutionContextImpl) ProcessWorkflowTask(workflowTask *workflo
 ProcessEvents:
 	for {
 		reorderedEvents, markers, binaryChecksum, historySizeEstimation, err := reorderedHistory.NextDecisionEvents()
-		w.workflowInfo.TotalHistoryBytes += int64(historySizeEstimation)
+		//w.workflowInfo.TotalHistoryBytes += int64(historySizeEstimation)
 		w.wth.logger.Info("Differences between history size estimation and actual size",
 			zap.Int("HistoryEstimation", historySizeEstimation),
 			zap.Int64("HistorySizeEstimation", w.workflowInfo.TotalHistoryBytes),