@@ -181,20 +181,15 @@ func (g *S3Getter) getObject(ctx context.Context, client *s3.S3, dst, bucket, ke
181
181
182
182
func (g * S3Getter ) getAWSConfig (region string , url * url.URL , creds * credentials.Credentials ) * aws.Config {
183
183
conf := & aws.Config {}
184
- if creds == nil {
185
- // Grab the metadata URL
186
- metadataURL := os .Getenv ("AWS_METADATA_URL" )
187
- if metadataURL == "" {
188
- metadataURL = "http://169.254.169.254:80/latest"
189
- }
190
-
184
+ metadataURLOverride := os .Getenv ("AWS_METADATA_URL" )
185
+ if creds == nil && metadataURLOverride != "" {
191
186
creds = credentials .NewChainCredentials (
192
187
[]credentials.Provider {
193
188
& credentials.EnvProvider {},
194
189
& credentials.SharedCredentialsProvider {Filename : "" , Profile : "" },
195
190
& ec2rolecreds.EC2RoleProvider {
196
191
Client : ec2metadata .New (session .New (& aws.Config {
197
- Endpoint : aws .String (metadataURL ),
192
+ Endpoint : aws .String (metadataURLOverride ),
198
193
})),
199
194
},
200
195
})
@@ -213,7 +208,7 @@ func (g *S3Getter) getAWSConfig(region string, url *url.URL, creds *credentials.
213
208
conf .Region = aws .String (region )
214
209
}
215
210
216
- return conf
211
+ return conf . WithCredentialsChainVerboseErrors ( true )
217
212
}
218
213
219
214
func (g * S3Getter ) parseUrl (u * url.URL ) (region , bucket , path , version string , creds * credentials.Credentials , err error ) {
0 commit comments