import redis

from api.utils import config


class RedisPools(object):
    EXPERIMENTS_STATUS = redis.ConnectionPool.from_url(
        config.get_string('POLYAXON_REDIS_EXPERIMENTS_STATUS_URL'))
    JOBS_STATUS = redis.ConnectionPool.from_url(
        config.get_string('POLYAXON_REDIS_JOBS_STATUS_URL'))
    JOB_CONTAINERS = redis.ConnectionPool.from_url(
        config.get_string('POLYAXON_REDIS_JOB_CONTAINERS_URL'))

import redis

from api.utils import config


class RedisPools(object):
    EXPERIMENTS_STATUS = redis.ConnectionPool.from_url(
        config.get_string('POLYAXON_REDIS_EXPERIMENTS_STATUS_URL'))
    JOBS_STATUS = redis.ConnectionPool.from_url(
        config.get_string('POLYAXON_REDIS_JOBS_STATUS_URL'))
    JOB_CONTAINERS = redis.ConnectionPool.from_url(
        config.get_string('POLYAXON_REDIS_JOB_CONTAINERS_URL'))
    TO_STREAM = redis.ConnectionPool.from_url(
        config.get_string('POLYAXON_REDIS_TO_STREAM_URL'))

Add to stream redis db
Add to stream redis db

  import redis
  
  from api.utils import config
  
  
  class RedisPools(object):
      EXPERIMENTS_STATUS = redis.ConnectionPool.from_url(
          config.get_string('POLYAXON_REDIS_EXPERIMENTS_STATUS_URL'))
      JOBS_STATUS = redis.ConnectionPool.from_url(
          config.get_string('POLYAXON_REDIS_JOBS_STATUS_URL'))
      JOB_CONTAINERS = redis.ConnectionPool.from_url(
          config.get_string('POLYAXON_REDIS_JOB_CONTAINERS_URL'))
+     TO_STREAM = redis.ConnectionPool.from_url(
+         config.get_string('POLYAXON_REDIS_TO_STREAM_URL'))
  
Add to stream redis db
## Code Before:
import redis

from api.utils import config


class RedisPools(object):
    EXPERIMENTS_STATUS = redis.ConnectionPool.from_url(
        config.get_string('POLYAXON_REDIS_EXPERIMENTS_STATUS_URL'))
    JOBS_STATUS = redis.ConnectionPool.from_url(
        config.get_string('POLYAXON_REDIS_JOBS_STATUS_URL'))
    JOB_CONTAINERS = redis.ConnectionPool.from_url(
        config.get_string('POLYAXON_REDIS_JOB_CONTAINERS_URL'))

## Instruction:
Add to stream redis db
## Code After:
import redis

from api.utils import config


class RedisPools(object):
    EXPERIMENTS_STATUS = redis.ConnectionPool.from_url(
        config.get_string('POLYAXON_REDIS_EXPERIMENTS_STATUS_URL'))
    JOBS_STATUS = redis.ConnectionPool.from_url(
        config.get_string('POLYAXON_REDIS_JOBS_STATUS_URL'))
    JOB_CONTAINERS = redis.ConnectionPool.from_url(
        config.get_string('POLYAXON_REDIS_JOB_CONTAINERS_URL'))
    TO_STREAM = redis.ConnectionPool.from_url(
        config.get_string('POLYAXON_REDIS_TO_STREAM_URL'))
