diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go index d8dea391de..6bd8401064 100644 --- a/flow/connectors/postgres/postgres.go +++ b/flow/connectors/postgres/postgres.go @@ -740,6 +740,7 @@ func (c *PostgresConnector) GetTableSchema( } tableSchema, err := c.getTableSchemaForTable(ctx, tableName, req.System) if err != nil { + c.logger.Info("error fetching schema for table "+tableName, slog.Any("error", err)) return nil, err } res[tableName] = tableSchema