diff --git a/lib/galaxy/jobs/handler.py b/lib/galaxy/jobs/handler.py index c549dec40b4..d7720bcaf00 100644 --- a/lib/galaxy/jobs/handler.py +++ b/lib/galaxy/jobs/handler.py @@ -8,7 +8,7 @@ import logging import threading from Queue import Queue, Empty -from sqlalchemy.sql.expression import and_, or_, select, func, true +from sqlalchemy.sql.expression import and_, or_, select, func, true, null from galaxy import model from galaxy.util.sleeper import Sleeper @@ -112,7 +112,7 @@ class JobHandlerQueue( object ): .outerjoin( model.User ) \ .filter( model.Job.state.in_( in_list ) & ( model.Job.handler == self.app.config.server_name ) & - or_( ( model.Job.user_id is None ), ( model.User.active == true() ) ) ).all() + or_( ( model.Job.user_id == null() ), ( model.User.active == true() ) ) ).all() else: jobs_at_startup = self.sa_session.query( model.Job ).enable_eagerloads( False ) \ .filter( model.Job.state.in_( in_list ) & @@ -212,7 +212,7 @@ class JobHandlerQueue( object ): .join(model.LibraryDatasetDatasetAssociation) \ .join(model.Dataset) \ .filter(and_((model.Job.state == model.Job.states.NEW), - or_((model.LibraryDatasetDatasetAssociation._state is not None), + or_((model.LibraryDatasetDatasetAssociation._state != null()), (model.LibraryDatasetDatasetAssociation.deleted == true()), (model.Dataset.state != model.Dataset.states.OK), (model.Dataset.deleted == true())))).subquery() @@ -220,7 +220,7 @@ class JobHandlerQueue( object ): jobs_to_check = self.sa_session.query(model.Job).enable_eagerloads(False) \ .outerjoin( model.User ) \ .filter(and_((model.Job.state == model.Job.states.NEW), - or_((model.Job.user_id is None), (model.User.active == true())), + or_((model.Job.user_id == null()), (model.User.active == true())), (model.Job.handler == self.app.config.server_name), ~model.Job.table.c.id.in_(hda_not_ready), ~model.Job.table.c.id.in_(ldda_not_ready))) \