···

       
141
       
141
       
 
       


     

       
142
       
142
       
 
       
		// add one to the count, every 500 ops execute the piepline

     

       
143
       
143
       
 
       
		eventCount += 1

     

       
144
       
144
       
-
       
		if eventCount%500 == 0 {

     

       
144
       
144
       
+
       
		if eventCount%2500 == 0 {

     

       
145
       
145
       
 
       
			if _, err := pipe.Exec(ctx); err != nil {

     

       
146
       
146
       
 
       
				log.Printf("failed to exec pipe\n")

     

       
147
       
147
       
 
       
			}