Skip to content

Commit

Permalink
Debug S3 Test Failures
Browse files Browse the repository at this point in the history
  • Loading branch information
iskakaushik committed Dec 20, 2023
1 parent 9ec86d4 commit f3fa1d1
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions flow/connectors/utils/avro/avro_writer.go
Original file line number Diff line number Diff line change
Expand Up @@ -216,8 +216,9 @@ func (p *peerDBOCFWriter) WriteRecordsToS3(bucketName, key string, s3Creds utils
Body: r,
})
if err != nil {
slog.Error("failed to upload file: ", slog.Any("error", err))
return nil, fmt.Errorf("failed to upload file: %w", err)
s3Path := "s3://" + bucketName + "/" + key
slog.Error("failed to upload file: ", slog.Any("error", err), slog.Any("s3_path", s3Path))
return nil, fmt.Errorf("failed to upload file to path %s: %w", s3Path, err)
}

slog.Info("file uploaded to" + result.Location)
Expand Down

0 comments on commit f3fa1d1

Please sign in to comment.