solar/run.sh
Dmitry Shulyak 4b1374577a Implement db based lock mechanism for orchestration
Current change allows us to use single worker for stateful
and stateless tasks, and add more workers in case of scaling issues.

Patch covers:
- locking with riak and n_val=1
- riak strongly consistent buckets (riak ensemble)
- sqlite based lock

To enable locking with riak ensemble solar config should be modified:
solar_db: riak://10.0.0.3:18087
riak_ensemble: True
lock_bucket_type: <<bucket_name>>

Change-Id: I5afddb35a944ff75efdf1159ad037536a9d8bbfb
2016-01-13 16:39:11 +02:00

9 lines
207 B
Bash
Executable File

#!/bin/bash
# required for ease of development
if [ -d /solar ]; then
cd /solar && python setup.py develop
fi
celery worker -A solar.orchestration.runner -P gevent -c 1000 -Q system_log,celery,scheduler