mirror of
https://github.com/galaxyproject/galaxy.git
synced 2026-09-24 16:30:27 +08:00
More typing fixes.
This commit is contained in:
@@ -10,36 +10,36 @@ from .utils import View
|
||||
|
||||
metadata = MetaData()
|
||||
|
||||
AGGREGATE_STATE_QUERY = """
|
||||
SELECT
|
||||
hdca.id as hdca_id,
|
||||
SUM(CASE WHEN state = 'new' THEN 1 ELSE 0 END) AS new,
|
||||
SUM(CASE WHEN state = 'resubmitted' THEN 1 ELSE 0 END) AS resubmitted,
|
||||
SUM(CASE WHEN state = 'waiting' THEN 1 ELSE 0 END) AS waiting,
|
||||
SUM(CASE WHEN state = 'queued' THEN 1 ELSE 0 END) AS queued,
|
||||
SUM(CASE WHEN state = 'running' THEN 1 ELSE 0 END) AS running,
|
||||
SUM(CASE WHEN state = 'ok' THEN 1 ELSE 0 END) AS ok,
|
||||
SUM(CASE WHEN state = 'error' THEN 1 ELSE 0 END) AS error,
|
||||
SUM(CASE WHEN state = 'failed' THEN 1 ELSE 0 END) AS failed,
|
||||
SUM(CASE WHEN state = 'paused' THEN 1 ELSE 0 END) AS paused,
|
||||
SUM(CASE WHEN state = 'deleted' THEN 1 ELSE 0 END) AS deleted,
|
||||
SUM(CASE WHEN state = 'deleted_new' THEN 1 ELSE 0 END) AS deleted_new,
|
||||
SUM(CASE WHEN state = 'upload' THEN 1 ELSE 0 END) AS upload,
|
||||
SUM(CASE WHEN job.id IS NOT NULL THEN 1 ELSE 0 END) AS all_jobs
|
||||
FROM history_dataset_collection_association hdca
|
||||
LEFT JOIN implicit_collection_jobs icj
|
||||
ON icj.id = hdca.implicit_collection_jobs_id
|
||||
LEFT JOIN implicit_collection_jobs_job_association icjja
|
||||
ON icj.id = icjja.implicit_collection_jobs_id
|
||||
LEFT JOIN job
|
||||
ON icjja.job_id = job.id
|
||||
GROUP BY hdca.id
|
||||
"""
|
||||
|
||||
|
||||
class HistoryDatasetCollectionJobStateSummary(View):
|
||||
|
||||
__view__ = text("""
|
||||
SELECT
|
||||
hdca.id as hdca_id,
|
||||
SUM(CASE WHEN state = 'new' THEN 1 ELSE 0 END) AS new,
|
||||
SUM(CASE WHEN state = 'resubmitted' THEN 1 ELSE 0 END) AS resubmitted,
|
||||
SUM(CASE WHEN state = 'waiting' THEN 1 ELSE 0 END) AS waiting,
|
||||
SUM(CASE WHEN state = 'queued' THEN 1 ELSE 0 END) AS queued,
|
||||
SUM(CASE WHEN state = 'running' THEN 1 ELSE 0 END) AS running,
|
||||
SUM(CASE WHEN state = 'ok' THEN 1 ELSE 0 END) AS ok,
|
||||
SUM(CASE WHEN state = 'error' THEN 1 ELSE 0 END) AS error,
|
||||
SUM(CASE WHEN state = 'failed' THEN 1 ELSE 0 END) AS failed,
|
||||
SUM(CASE WHEN state = 'paused' THEN 1 ELSE 0 END) AS paused,
|
||||
SUM(CASE WHEN state = 'deleted' THEN 1 ELSE 0 END) AS deleted,
|
||||
SUM(CASE WHEN state = 'deleted_new' THEN 1 ELSE 0 END) AS deleted_new,
|
||||
SUM(CASE WHEN state = 'upload' THEN 1 ELSE 0 END) AS upload,
|
||||
SUM(CASE WHEN job.id IS NOT NULL THEN 1 ELSE 0 END) AS all_jobs
|
||||
FROM history_dataset_collection_association hdca
|
||||
LEFT JOIN implicit_collection_jobs icj
|
||||
ON icj.id = hdca.implicit_collection_jobs_id
|
||||
LEFT JOIN implicit_collection_jobs_job_association icjja
|
||||
ON icj.id = icjja.implicit_collection_jobs_id
|
||||
LEFT JOIN job
|
||||
ON icjja.job_id = job.id
|
||||
GROUP BY hdca.id
|
||||
""")
|
||||
|
||||
__view__ = __view__.columns(
|
||||
__view__ = text(AGGREGATE_STATE_QUERY).columns(
|
||||
column('hdca_id', Integer),
|
||||
column('new', Integer),
|
||||
column('resubmitted', Integer),
|
||||
|
||||
@@ -16,7 +16,7 @@ warnings.filterwarnings("ignore", message=r"[\n.]DEPRECATION: Python 2", module=
|
||||
try:
|
||||
from cwltool import expression
|
||||
except ImportError:
|
||||
expression = None
|
||||
expression = None # type: ignore
|
||||
|
||||
from galaxy.tools.expressions import evaluate
|
||||
|
||||
|
||||
Reference in New Issue
Block a user