Untitled
unknown
plain_text
2 years ago
910 B
9
Indexable
def get_existing_tests_status_summary(self):
query = f"SELECT " \
f"SUM(CASE WHEN {WORKFLOW_COLUMNS['status'][0]} = 'QUEUE' THEN 1 ELSE 0 END) AS queue_result, " \
f"SUM(CASE WHEN {WORKFLOW_COLUMNS['status'][0]} = 'SCHEDULED' THEN 1 ELSE 0 END) AS scheduled_result, " \
f"SUM(CASE WHEN {WORKFLOW_COLUMNS['status'][0]} = 'STARTING' THEN 1 ELSE 0 END) AS starting_result, " \
f"SUM(CASE WHEN {WORKFLOW_COLUMNS['status'][0]} = 'IN_PROGRESS' THEN 1 ELSE 0 END) AS in_progress_result " \
f"FROM {WORKFLOW_TABLE_NAME};"
results = self.db.execute_dql_query(query)["results"][0]
status_dict = {
'queue': results['queue_result'],
'scheduled': results['scheduled_result'],
'starting': results['starting_result'],
'in_progress': results['in_progress_result']
}
return {'status_statistics': status_dict}Editor is loading...
Leave a Comment