Skip to content

Commit

Permalink
chore: support replay with iam role (#3560)
Browse files Browse the repository at this point in the history
  • Loading branch information
cisse21 committed Jun 30, 2023
1 parent 8975dcc commit f471fb0
Showing 1 changed file with 2 additions and 11 deletions.
13 changes: 2 additions & 11 deletions enterprise/replay/setup.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,7 +9,6 @@ import (
"github.com/rudderlabs/rudder-go-kit/logger"
"github.com/rudderlabs/rudder-server/jobsdb"
"github.com/rudderlabs/rudder-server/utils/filemanagerutil"
"github.com/rudderlabs/rudder-server/utils/misc"
"github.com/rudderlabs/rudder-server/utils/types"
)

Expand All @@ -28,18 +27,10 @@ func initFileManager(log logger.Logger) (filemanager.FileManager, string, error)
}

provider := config.GetString("JOBS_BACKUP_STORAGE_PROVIDER", "S3")

configFromEnv := filemanagerutil.ProviderConfigOpts(context.TODO(), provider, config.Default)
uploader, err := filemanager.New(&filemanager.Settings{
Provider: provider,
Config: misc.GetObjectStorageConfig(misc.ObjectStorageOptsT{
Provider: provider,
Config: configFromEnv,
UseRudderStorage: false,
// TODO: need to figure out how to bring workspaceID here
// when we support IAM role here.
}),
Conf: config.Default,
Config: filemanager.GetProviderConfigFromEnv(filemanagerutil.ProviderConfigOpts(context.TODO(), provider, config.Default)),
Conf: config.Default,
})
if err != nil {
log.Errorf("[[ Replay ]] Error creating file manager: %s", err.Error())
Expand Down

0 comments on commit f471fb0

Please sign in to comment.