"""
_FindNewExpressRuns_

Oracle implementation of FindNewExpressRuns

Return all runs that haven't had Express released

"""

from WMCore.Database.DBFormatter import DBFormatter

class FindNewExpressRuns(DBFormatter):

    def execute(self, conn = None, transaction = False):

        sql = """SELECT run.run_id
                 FROM run
                 WHERE checkForZeroState(run.express_released) = 0
                 """

        results = self.dbi.processData(sql, {}, conn = conn,
                                       transaction = transaction)[0].fetchall()

        runs = []
        for result in results:
            runs.append(result[0])

        return runs

ca100c71028e9f89ad3c8a1603b5e3ed032b3082
<mask token>

<mask token>


class FindNewExpressRuns(DBFormatter):
    <mask token>

<mask token>


class FindNewExpressRuns(DBFormatter):

    def execute(self, conn=None, transaction=False):
        sql = """SELECT run.run_id
                 FROM run
                 WHERE checkForZeroState(run.express_released) = 0
                 """
        results = self.dbi.processData(sql, {}, conn=conn, transaction=
            transaction)[0].fetchall()
        runs = []
        for result in results:
            runs.append(result[0])
        return runs

<mask token>
from WMCore.Database.DBFormatter import DBFormatter


class FindNewExpressRuns(DBFormatter):

    def execute(self, conn=None, transaction=False):
        sql = """SELECT run.run_id
                 FROM run
                 WHERE checkForZeroState(run.express_released) = 0
                 """
        results = self.dbi.processData(sql, {}, conn=conn, transaction=
            transaction)[0].fetchall()
        runs = []
        for result in results:
            runs.append(result[0])
        return runs

"""
_FindNewExpressRuns_

Oracle implementation of FindNewExpressRuns

Return all runs that haven't had Express released

"""

from WMCore.Database.DBFormatter import DBFormatter

class FindNewExpressRuns(DBFormatter):

    def execute(self, conn = None, transaction = False):

        sql = """SELECT run.run_id
                 FROM run
                 WHERE checkForZeroState(run.express_released) = 0
                 """

        results = self.dbi.processData(sql, {}, conn = conn,
                                       transaction = transaction)[0].fetchall()

        runs = []
        for result in results:
            runs.append(result[0])

        return runs
