From 384b4e63e99ad5570b07c467ca29ddf9d0d2d422 Mon Sep 17 00:00:00 2001
From: Dmitry Shulyak <dshulyak@mirantis.com>
Date: Tue, 12 Jan 2016 16:58:43 +0200
Subject: [PATCH] Change celery config to use sqlite backend messaging and
 results

SQLite database file will be located in /tmp/celery.db

Change-Id: I230997f01d2f37efc8897d6c489aee3900bff6c3
---
 .config                       | 4 +++-
 requirements.txt              | 4 ++--
 solar/config.py               | 3 ++-
 solar/orchestration/runner.py | 7 ++-----
 4 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/.config b/.config
index db066f82..8d3f9043 100644
--- a/.config
+++ b/.config
@@ -1,3 +1,5 @@
-redis: redis://localhost:6379/1
+
+celery_broker: sqla+sqlite:////tmp/celery.db
+celery_backend: db+sqlite:////tmp/celery.db
 solar_db: sqlite:////tmp/solar.db
 # solar_db: riak://10.0.0.2:8087
diff --git a/requirements.txt b/requirements.txt
index 320ba97a..9b49bb53 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -8,8 +8,6 @@ jsonschema==2.4.0
 requests
 dictdiffer==0.4.0
 enum34==1.0.4
-redis==2.10.3
-fakeredis
 inflection
 Fabric==1.10.2
 tabulate==0.7.5
@@ -27,6 +25,8 @@ wrapt
 peewee
 # if you want to use lua computable inputs
 # lupa
+# required for celery sql backends
+sqlalchemy
 
 
 # if you want to use complex version check in repositories
diff --git a/solar/config.py b/solar/config.py
index 674fd6fb..c9290122 100644
--- a/solar/config.py
+++ b/solar/config.py
@@ -23,7 +23,8 @@ import yaml
 CWD = os.getcwd()
 
 C = Bunch(solar_db="")
-C.redis = 'redis://localhost:6379/1'
+C.celery_broker = 'sqla+sqlite:////tmp/celery.db'
+C.celery_backend = 'db+sqlite:////tmp/celery.db'
 
 
 def _lookup_vals(setter, config, prefix=None):
diff --git a/solar/orchestration/runner.py b/solar/orchestration/runner.py
index 40f272e4..4ac65098 100644
--- a/solar/orchestration/runner.py
+++ b/solar/orchestration/runner.py
@@ -15,14 +15,11 @@
 from celery import Celery
 
 from solar.config import C
-from solar.utils import parse_database_conn
 
-conn, _ = parse_database_conn(C.redis)
-_url = 'redis://{}:{}/{}'.format(conn.host, conn.port, conn.database)
 
 app = Celery(
     include=['solar.system_log.tasks', 'solar.orchestration.tasks'],
-    backend=_url,
-    broker=_url)
+    broker=C.celery_broker,
+    backend=C.celery_backend)
 app.conf.update(CELERY_ACCEPT_CONTENT=['json'])
 app.conf.update(CELERY_TASK_SERIALIZER='json')