Untitled

 avatar
unknown
plain_text
a year ago
910 B
6
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