opensource/galaxy
3
0
Fork 0
mirror of https://github.com/galaxyproject/galaxy.git synced 2026-09-21 13:50:20 +08:00
Code Issues Packages Projects Releases Wiki Activity

AMQP listener now updates request_event table when all samples have finished processing

Browse Source
This commit is contained in:
Ramkrishna Chakrabarty
2009-12-07 14:45:09 -05:00
parent 8ff7f8f853
commit ec1aac46e4
1 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
scripts/galaxy_messaging/server/galaxydb_interface.py
+8 -6
View File
@@ -33,6 +33,7 @@ class GalaxyDbInterface(object):
self.event_table = Table('sample_event', self.metadata, autoload=True )
self.sample_table = Table('sample', self.metadata, autoload=True )
self.request_table = Table('request', self.metadata, autoload=True )
self.request_event_table = Table('request_event', self.metadata, autoload=True )
self.state_table = Table('sample_state', self.metadata, autoload=True )
def get_sample_id(self, field_name='bar_code', value=None):
@@ -118,12 +119,13 @@ class GalaxyDbInterface(object):
break
if request_complete:
request_state = 'Complete'
else:
request_state = 'Submitted'
log.debug('Updating request_id %i state to "%s"' % (self.request_id, request_state))
i = self.request_table.update(whereclause=self.request_table.c.id==self.request_id,
values={self.request_table.c.state: request_state})
i.execute()
log.debug('Updating request_id %i state to "%s"' % (self.request_id, request_state))
i = self.request_event_table.insert()
i.execute(update_time=datetime.utcnow(),
create_time=datetime.utcnow(),
request_id=self.request_id,
state=request_state,
comment='All samples of this request have finished processing.')