@@ -29,18 +29,22 @@ func init() {
29
29
logger , _ := zap .NewDevelopment ()
30
30
defer logger .Sync ()
31
31
log = logger .Sugar ()
32
- cwd , _ := os .Getwd ()
33
- dataDir := path .Join (cwd , "data" )
34
- if _ , err := os .Stat (dataDir ); err != nil && os .IsNotExist (err ) {
35
- if err := os .MkdirAll (dataDir , os .ModePerm ); err != nil {
36
- log .Fatal ("error creating data directory,%s" , err )
32
+ //KO_DATA_PATH will be available only when running with ko container
33
+ dataDir , ok := os .LookupEnv ("KO_DATA_PATH" )
34
+ if ! ok {
35
+ cwd , _ := os .Getwd ()
36
+ dataDir = path .Join (cwd , "data" )
37
+ if _ , err := os .Stat (dataDir ); err != nil && os .IsNotExist (err ) {
38
+ if err := os .MkdirAll (dataDir , os .ModePerm ); err != nil {
39
+ log .Fatal ("error creating data directory,%s" , err )
40
+ }
37
41
}
38
42
}
39
43
dbFile := path .Join (dataDir , "sequence.db" )
40
44
log .Infof ("Data File:%s" , dbFile )
41
45
sc , err = utils .NewSequence (fmt .Sprintf ("file://%s?cache=shared" , dbFile ))
42
46
if err != nil {
43
- log .Fatal ("error initializing sequence DB,%s" , err )
47
+ log .Fatalf ("error initializing sequence DB,%s" , err )
44
48
}
45
49
}
46
50
0 commit comments