removing debugging logs

streamingfast · Feb 27, 2024 · a6f2bef · a6f2bef
1 parent c02ee05
commit a6f2bef
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 10 deletions.
diff --git a/pipeline/process_block.go b/pipeline/process_block.go
@@ -252,9 +252,6 @@ func (p *Pipeline) handleStepNew(ctx context.Context, block *pbbstream.Block, cl
 	}
 
 	dmetering.GetBytesMeter(ctx).CountInc("wasm_input_bytes", len(block.Payload.Value))
-	if block.Number%100 == 0 {
-		logger.Debug("comparing block payload size", zap.Int("wasm_input_bytes", len(block.Payload.Value)), zap.Int("wasm_input_bytes_count", dmetering.GetBytesMeter(ctx).GetCount("wasm_input_bytes")))
-	}
 
 	if err := p.executeModules(ctx, execOutput); err != nil {
 		return fmt.Errorf("execute modules: %w", err)

diff --git a/service/metering.go b/service/metering.go
@@ -18,13 +18,6 @@ func sendMetering(meter dmetering.Meter, userID, apiKeyID, ip, userMeta, endpoin
 	inputBytes := meter.GetCount("wasm_input_bytes")
 	meter.ResetCount("wasm_input_bytes")
 
-	logger.Debug("sending metering event",
-		zap.Uint64("bytes_read", bytesRead),
-		zap.Uint64("bytes_written", bytesWritten),
-		zap.Int("wasm_input_bytes", inputBytes),
-		zap.Int("egress_bytes", egressBytes),
-	)
-
 	event := dmetering.Event{
 		UserID:    userID,
 		ApiKeyID:  apiKeyID,