for _, event := range bufferEvents {
switch event.GetEventType() {
attributes := event.GetActivityTaskStartedEventAttributes()
scheduledEventID := attributes.GetScheduledEventId()
b.scheduledIDToStartedID[scheduledEventID] = event.GetEventId()
case enumspb.EVENT_TYPE_ACTIVITY_TASK_COMPLETED:
attributes := event.GetActivityTaskCompletedEventAttributes()