Skip to content

Commit 487b5b6

Browse files
authored
Reduce error noise from log retention check (#3595)
Postgres pipes emit a lot of visible errors
1 parent 75e4cd3 commit 487b5b6

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

flow/activities/flowable.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1182,10 +1182,10 @@ func (a *FlowableActivity) emitLogRetentionHours(
11821182
}
11831183
ctx = context.WithValue(ctx, internal.FlowMetadataKey, flowMetadata)
11841184
srcConn, err := connectors.GetByNameAs[connectors.GetLogRetentionConnector](ctx, nil, a.CatalogPool, info.config.SourceName)
1185-
if err != nil {
1186-
if !errors.Is(err, errors.ErrUnsupported) {
1187-
logger.Error("Failed to create connector to emit log retention", slog.Any("error", err))
1188-
}
1185+
if errors.Is(err, errors.ErrUnsupported) {
1186+
return nil
1187+
} else if err != nil {
1188+
logger.Error("Failed to create connector to emit log retention", slog.Any("error", err))
11891189
return err
11901190
}
11911191
defer connectors.CloseConnector(ctx, srcConn)

0 commit comments

Comments
 (0)