Hi Raj, These are the changes the customer did to migrate.py
------------------------------------------------------------------------------------------- root@sv-1:~# diff -up /usr/local/lib/python2.7/dist-packages/contrail_provisioning/database/migrate.py.org /usr/local/lib/python2.7/dist-packages/contrail_provisioning/database/migrate.py --- /usr/local/lib/python2.7/dist-packages/contrail_provisioning/database/migrate.py.org 2016-11-29 15:54:43.733510099 +0900 +++ /usr/local/lib/python2.7/dist-packages/contrail_provisioning/database/migrate.py 2016-11-29 15:54:44.825510017 +0900 @@ -50,7 +50,12 @@ class DatabaseMigrate(DatabaseCommon): self._args = parser.parse_args(self.remaining_argv)
def stop_cassandra(self): - local('service cassandra stop') + with settings(warn_only=True): + while True: + local("service cassandra stop; sleep 5") + result = local("ps -ef | grep cassandr[a]") + if result.failed: + break
def force_stop_cassandra(self): local('kill `ps auxw | grep -E "Dcassandra-pidfile=.*cassandra\.pid" | grep -v grep | awk \'{print $2}\'`') @@ -59,6 +64,13 @@ class DatabaseMigrate(DatabaseCommon): local('service contrail-database stop')
def upgrade_sstables_and_drain(self): + with settings(warn_only=True): + while True: + result = local("nodetool status > /dev/null") + if result.succeeded: + break + else: + local("sleep 5") print 'Upgrading database sstables...' local('nodetool upgradesstables') local('nodetool drain') -------------------------------------------------------------------------------------------
Hi Raj, These are the changes the customer did to migrate.py
------- ------- ------- ------- ------- ------- ------- ------- ------- ------- ------- ------- ------- lib/python2. 7/dist- packages/ contrail_ provisioning/ database/ migrate. py.org /usr/local/ lib/python2. 7/dist- packages/ contrail_ provisioning/ database/ migrate. py lib/python2. 7/dist- packages/ contrail_ provisioning/ database/ migrate. py.org 2016-11-29 15:54:43.733510099 +0900 lib/python2. 7/dist- packages/ contrail_ provisioning/ database/ migrate. py 2016-11-29 15:54:44.825510017 +0900 (DatabaseCommon ): parse_args( self.remaining_ argv)
root@sv-1:~# diff -up /usr/local/
--- /usr/local/
+++ /usr/local/
@@ -50,7 +50,12 @@ class DatabaseMigrate
self._args = parser.
def stop_cassandra( self): warn_only= True):
- local('service cassandra stop')
+ with settings(
+ while True:
+ local("service cassandra stop; sleep 5")
+ result = local("ps -ef | grep cassandr[a]")
+ if result.failed:
+ break
def force_stop_ cassandra( self): pidfile= .*cassandra\ .pid" | grep -v grep | awk \'{print $2}\'`') (DatabaseCommon ):
local('kill `ps auxw | grep -E "Dcassandra-
@@ -59,6 +64,13 @@ class DatabaseMigrate
local('service contrail-database stop')
def upgrade_ sstables_ and_drain( self): warn_only= True): ------- ------- ------- ------- ------- ------- ------- ------- ------- ------- ------- -------
+ with settings(
+ while True:
+ result = local("nodetool status > /dev/null")
+ if result.succeeded:
+ break
+ else:
+ local("sleep 5")
print 'Upgrading database sstables...'
local('nodetool upgradesstables')
local('nodetool drain')
-------