You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by de...@apache.org on 2019/02/18 15:07:38 UTC
svn commit: r1853804 - in /uima/uima-ducc/trunk/src/main/admin: ducc_util.py
start_ducc
Author: degenaro
Date: Mon Feb 18 15:07:37 2019
New Revision: 1853804
URL: http://svn.apache.org/viewvc?rev=1853804&view=rev
Log:
UIMA-5742 Reliable DUCC
> prevent start of DB when automanage == False
Modified:
uima/uima-ducc/trunk/src/main/admin/ducc_util.py
uima/uima-ducc/trunk/src/main/admin/start_ducc
Modified: uima/uima-ducc/trunk/src/main/admin/ducc_util.py
URL: http://svn.apache.org/viewvc/uima/uima-ducc/trunk/src/main/admin/ducc_util.py?rev=1853804&r1=1853803&r2=1853804&view=diff
==============================================================================
--- uima/uima-ducc/trunk/src/main/admin/ducc_util.py (original)
+++ uima/uima-ducc/trunk/src/main/admin/ducc_util.py Mon Feb 18 15:07:37 2019
@@ -352,6 +352,10 @@ class DuccUtil(DuccBase):
def db_start(self):
+ if(not self.automanage_database):
+ print ' (Bypass database start - not automanaged)'
+ return False
+
# bypass all of this for the initial delivery
if ( self.db_bypass == True) :
print ' (Bypass database start)'
@@ -408,6 +412,9 @@ class DuccUtil(DuccBase):
def db_stop(self):
try:
+ if(not self.automanage_database):
+ print ' (Bypass database start - not automanaged)'
+ return False
if ( self.db_bypass == True) :
print ' (Bypass database stop)'
return True
Modified: uima/uima-ducc/trunk/src/main/admin/start_ducc
URL: http://svn.apache.org/viewvc/uima/uima-ducc/trunk/src/main/admin/start_ducc?rev=1853804&r1=1853803&r2=1853804&view=diff
==============================================================================
--- uima/uima-ducc/trunk/src/main/admin/start_ducc (original)
+++ uima/uima-ducc/trunk/src/main/admin/start_ducc Mon Feb 18 15:07:37 2019
@@ -79,6 +79,13 @@ class StartDucc(DuccUtil):
if (com in self.local_components):
node = self.localhost
+ if(self.automanage_database):
+ pass
+ else:
+ if (com in ['db', 'database']):
+ msgs.append(('Unmanaged component', component))
+ return msgs
+
if ((com in self.default_components) or ( com == 'agent')) :
msgs.append((node, 'Starting', com))
else:
@@ -278,9 +285,19 @@ class StartDucc(DuccUtil):
components.append('rm')
components.append('sm')
components.append('ws')
- components.append('db')
components.append('broker')
+ if(self.automanage_database):
+ components.append('db')
else:
+ if(self.automanage_database):
+ pass
+ else:
+ if('db' in a):
+ print "Database not automanaged."
+ return
+ if('database' in a):
+ print "Database not automanaged."
+ return
components.append(a)
elif o in ( '-n', '--nodelist' ):
nodefiles.append(a)
@@ -343,18 +360,19 @@ class StartDucc(DuccUtil):
print "Limits too low to run DUCC"
sys.exit(1)
- if ( self.automanage_database and ('db' in components) ):
- try:
- if ( not self.db_start() ):
- print "Failed to start or connect to the database."
+ if ( self.automanage_database ):
+ if ( 'db' in components ):
+ try:
+ if ( not self.db_start() ):
+ print "Failed to start or connect to the database."
+ sys.exit(1)
+ node = self.get_db_host()
+ com = 'database'
+ self.db_acct_start(node,com)
+ except Exception (e):
+ # print e
+ print sys.exc_info()[0], "Can't start the database."
sys.exit(1)
- node = self.get_db_host()
- com = 'database'
- self.db_acct_start(node,com)
- except Exception (e):
- # print e
- print sys.exc_info()[0], "Can't start the database."
- sys.exit(1)
if ( len(components) == 1 ):
if ( self.automanage_database and ('db' in components) ):