M shared/storage/sqlite/writer.go →
shared/storage/sqlite/writer.go }
func NewWriter(conn *sql.DB, logger *log.Logger, opts *Options) (*Writer, error) {
- _, err := conn.Exec(schema)
+ ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
+ defer cancel()
+ _, err := conn.ExecContext(ctx, schema)
if err != nil {
return nil, fault.Wrap(err, fmsg.With("creating tables"))
}