Skip to content

Commit f4502ca

Browse files
committed
feat: better log info for when inboxes not updating the DB
1 parent f179430 commit f4502ca

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

sda/cmd/ingest/ingest.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -321,11 +321,11 @@ func (app *Ingest) ingestFile(correlationID string, message schema.IngestionTrig
321321
return "ack"
322322
}
323323
case "":
324-
// Catch all for inboxes that doesn't update the DB
325-
log.Infof("ingesting unregistered file, correlation-id: %s", correlationID)
324+
// Catch all for implementations that don't update the DB, e.g. for those not using S3inbox or sftpInbox
325+
log.Infof("registering file, correlation-id: %s", correlationID)
326326
fileID, err = app.DB.RegisterFile(message.FilePath, message.User)
327327
if err != nil {
328-
log.Errorf("InsertFile failed, correlation-id: %s, reason: (%s)", correlationID, err.Error())
328+
log.Errorf("failed to register file, correlation-id: %s, reason: (%s)", correlationID, err.Error())
329329

330330
return "nack"
331331
}

0 commit comments

Comments
 (0)