diff --git a/build/test/Dockerfile b/build/test/Dockerfile index cb9f1dd4..46d9bec7 100644 --- a/build/test/Dockerfile +++ b/build/test/Dockerfile @@ -73,7 +73,7 @@ COPY --from=0 /workspace/test.test . COPY build/test/entrypoint.sh . # create output directory -RUN mkdir /workspace/test/output && chmod 777 /workspace/test/output +RUN mkdir /workspace/test/output && chmod 4777 /workspace/test/output # run tests USER egress diff --git a/pkg/config/output_file.go b/pkg/config/output_file.go index 2805efb6..674764ed 100644 --- a/pkg/config/output_file.go +++ b/pkg/config/output_file.go @@ -9,7 +9,6 @@ import ( "github.com/livekit/egress/pkg/types" "github.com/livekit/protocol/livekit" - "github.com/livekit/protocol/logger" ) type FileConfig struct { @@ -127,7 +126,6 @@ func (o *FileConfig) updateFilepath(p *PipelineConfig, identifier string, replac if o.UploadConfig == nil { if dir != "" { // create local directory - logger.Debugw(fmt.Sprintf("creating dir %s", dir)) if err := os.MkdirAll(dir, 0755); err != nil { return err } @@ -139,8 +137,7 @@ func (o *FileConfig) updateFilepath(p *PipelineConfig, identifier string, replac tempDir := path.Join(p.LocalOutputDirectory, p.Info.EgressId) // create temporary directory - logger.Debugw(fmt.Sprintf("creating tempDir %s", tempDir)) - if err := os.MkdirAll(tempDir, 0755); err != nil { + if err := os.Mkdir(tempDir, 0755); err != nil { return err } diff --git a/pkg/config/service.go b/pkg/config/service.go index a3c70da0..4009dee5 100644 --- a/pkg/config/service.go +++ b/pkg/config/service.go @@ -80,6 +80,9 @@ func NewServiceConfig(confString string) (*ServiceConfig, error) { if conf.LocalOutputDirectory == "." { conf.LocalOutputDirectory = os.TempDir() } + if err := os.MkdirAll(conf.LocalOutputDirectory, 0755); err != nil { + return nil, err + } if err := conf.initLogger("nodeID", conf.NodeID, "clusterID", conf.ClusterID); err != nil { return nil, err