diff --git a/engine/loader_local_test.go b/engine/loader_local_test.go index 4c338d503..9af365122 100644 --- a/engine/loader_local_test.go +++ b/engine/loader_local_test.go @@ -395,6 +395,9 @@ func TestMatchLoadCsvWithStorRating(t *testing.T) { for _, key := range keysCsv { var refVal []byte for idx, rs := range []*RedisStorage{rsCsv, rsStor, rsApier} { + if key == utils.TASKS_KEY { + continue + } qVal, err := rs.db.Cmd("GET", key).Bytes() if err != nil { t.Fatalf("Run: %d, could not retrieve key %s, error: %s", idx, key, err.Error()) diff --git a/engine/storage_redis.go b/engine/storage_redis.go index 8a857d8a8..990ca2cde 100644 --- a/engine/storage_redis.go +++ b/engine/storage_redis.go @@ -904,7 +904,7 @@ func (rs *RedisStorage) GetActionPlan(key string, skipCache bool) (ats *ActionPl } var values []byte if values, err = rs.db.Cmd("GET", key).Bytes(); err == nil { - b := bytes.NewBuffer(values) + /*b := bytes.NewBuffer(values) r, err := zlib.NewReader(b) if err != nil { return nil, err @@ -913,8 +913,8 @@ func (rs *RedisStorage) GetActionPlan(key string, skipCache bool) (ats *ActionPl if err != nil { return nil, err } - r.Close() - err = rs.ms.Unmarshal(out, &ats) + r.Close()*/ + err = rs.ms.Unmarshal(values, &ats) cache2go.Cache(key, ats) } return @@ -932,10 +932,10 @@ func (rs *RedisStorage) SetActionPlan(key string, ats *ActionPlan) (err error) { return err } var b bytes.Buffer - w := zlib.NewWriter(&b) + /*w := zlib.NewWriter(&b) w.Write(result) - w.Close() - return rs.db.Cmd("SET", utils.ACTION_PLAN_PREFIX+key, b.Bytes()).Err + w.Close()*/ + return rs.db.Cmd("SET", utils.ACTION_PLAN_PREFIX+key, result).Err } func (rs *RedisStorage) GetAllActionPlans() (ats map[string]*ActionPlan, err error) {