Skip to content

Commit

Permalink
fix: log processing error
Browse files Browse the repository at this point in the history
  • Loading branch information
didil committed Aug 29, 2023
1 parent 517f76e commit e651576
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 1 deletion.
1 change: 1 addition & 0 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@ Inhooks listens to HTTP webhooks and saves the messages to Redis. A processing m
- Fast, concurrent processing
- Supports delayed processing
- Supports retries on failure with configurable number of attempts, interval and constant or exponential backoff
- Supports different HTTP payloads types: JSON, x-www-form-urlencoded, multipart/form-data
- ... more features planned

## Usage
Expand Down
2 changes: 1 addition & 1 deletion pkg/supervisor/ready.go
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,7 @@ func (s *Supervisor) startReadyProcessor(ctx context.Context, f *models.Flow, si

processingErr := s.messageProcessor.Process(ctx, sink, m)
if processingErr != nil {
logger.Info("message processing failed")
logger.Info("message processing failed", zap.Error(processingErr))
queuedInfo, err := s.processingResultsSvc.HandleFailed(ctx, sink, m, processingErr)
if err != nil {
logger.Error("could not handle failed processing", zap.Error(err))
Expand Down

0 comments on commit e651576

Please sign in to comment.