commit/galaxy-central: natefoo: Avoid a race condition in handling LWR status updates received via AMQP at startup.
1 new commit in galaxy-central: https://bitbucket.org/galaxy/galaxy-central/commits/a6729bbd904a/ Changeset: a6729bbd904a User: natefoo Date: 2014-06-19 14:46:21 Summary: Avoid a race condition in handling LWR status updates received via AMQP at startup. Affected #: 1 file diff -r c182d156b93ea7f824b232e6d17d2ed9bf24f430 -r a6729bbd904a2ad44544f9f7077e663482f89309 lib/galaxy/jobs/runners/lwr.py --- a/lib/galaxy/jobs/runners/lwr.py +++ b/lib/galaxy/jobs/runners/lwr.py @@ -156,6 +156,10 @@ return job_state def __async_update( self, full_status ): + while not hasattr( self.app, 'job_manager' ): + # The status update thread can start consuming before app is done initializing + log.debug( 'Received a status update message before app is initialized, waiting 5 seconds' ) + sleep( 5 ) job_id = None try: job_id = full_status[ "job_id" ] Repository URL: https://bitbucket.org/galaxy/galaxy-central/ -- This is a commit notification from bitbucket.org. You are receiving this because you have the service enabled, addressing the recipient of this email.
participants (1)
-
commits-noreply@bitbucket.org