Commit e8338e96 by Kohl Krisztofer

First 3.6 version

parent 4380caf8
......@@ -69,7 +69,7 @@ class Disk(object):
def deserialize(cls, desc):
"""Create cls object from JSON."""
logging.info(desc)
if isinstance(desc, basestring):
if isinstance(desc, str):
desc = json.loads(desc)
return cls(**desc)
......@@ -93,8 +93,8 @@ class Disk(object):
"""Get absolute path for disk's base image."""
return os.path.realpath(self.dir + '/' + self.base_name)
def __unicode__(self):
return u'%s %s %s %s' % (self.get_path(), self.format,
def __str__(self):
return '%s %s %s %s' % (self.get_path(), self.format,
self.size, self.get_base())
@classmethod
......
......@@ -45,7 +45,7 @@ project::
Set up default Storage configuration and activate the virtual environment::
$ cat >>/home/cloud/.virtualenvs/storage/bin/postactivate <<END
export AMQP_URI='amqp://cloud:password@host:5672/circle'
export AMQP_URI='amqp://cloud:cloud123@localhost:5672/circle'
END
$ workon storage
$ cd ~/storagedriver
......
......@@ -8,8 +8,8 @@ setgid cloud
instance $NAME
script
cd /home/cloud/storagedriver/
. /home/cloud/.virtualenvs/storagedriver/local/bin/activate
. /home/cloud/.virtualenvs/storagedriver/local/bin/postactivate
cd /home/kohlkriszto/Documents/storagedriver
. /home/kohlkriszto/Documents/storagedriver_venv/bin/activate
. /home/kohlkriszto/Documents/storagedriver_venv/bin/postactivate
exec celery -A storagecelery worker --loglevel=info -n $NAME
end script
......@@ -12,4 +12,4 @@ Restart=always
WorkingDirectory=/home/cloud/storagedriver
ExecStart=/bin/bash -c "source /etc/profile; workon storagedriver; exec celery -A storagecelery worker --loglevel=info -n $(/bin/hostname -s).%I"
ExecStart=/bin/bash -c "source /home/cloud/.virtualenvs/storage/bin/activate; source /home/cloud/.virtualenvs/storage/bin/postactivate; exec celery -A storagecelery worker --loglevel=info -n $(/bin/hostname -s).%I"
celery==3.1.17
requests==2.5.3
filemagic==1.6
celery
requests
filemagic
......@@ -22,8 +22,8 @@ celery = Celery('storagedriver',
include=['storagedriver'])
celery.conf.update(
CELERY_RESULT_BACKEND='amqp',
CELERY_TASK_RESULT_EXPIRES=300,
CELERY_RESULT_BACKEND='amqp://',
CELERY_TASK_RESULT_EXPIRES=30000,
CELERY_QUEUES=(
Queue(HOSTNAME, Exchange(
'storagedriver', type='direct'), routing_key='storagedriver'),
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or sign in to comment