From de1b7749584b514a8920e8898a45e5125b96a512 Mon Sep 17 00:00:00 2001
From: Jason Bornstein <131717043+jasonbornsteinMOOV@users.noreply.github.com>
Date: Mon, 2 Oct 2023 16:19:51 -0400
Subject: [PATCH] fix flow

---
 internal/pipeline/file_receiver.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/internal/pipeline/file_receiver.go b/internal/pipeline/file_receiver.go
index b934b0e..83a283a 100644
--- a/internal/pipeline/file_receiver.go
+++ b/internal/pipeline/file_receiver.go
@@ -274,7 +274,7 @@ func (fr *FileReceiver) processMessage(msg *pubsub.Message) error {
 
 	event, readErr := models.Read(data)
 	if readErr != nil {
-		return logger.LogErrorf("unable to read %s event: %v", event.Type, readErr).Err()
+		logger.LogErrorf("unable to read %s event: %v", event.Type, readErr)
 	}
 
 	var file *incoming.ACHFile