def process_task_completion()

in src/hpcadvisor/data_collector.py [0:0]

• 22 lines of code
• 3 McCabe index (conditional complexity)

def process_task_completion(task, task_status, tasks_file, dataset_file):

    jobname = task["tags"]["jobname"]
    taskid = task["tags"]["taskid"]
    poolname = task["tags"]["poolname"]
    ppr_perc = task["ppr"]
    appinputs = task["appinputs"]
    appname = task["appname"]
    tags = task["tags"]

    # TODO change signature for store_task_execution_data
    if task_status == taskset_handler.TaskStatus.COMPLETED:
        batch_handler.store_task_execution_data(
            poolname,
            jobname,
            taskid,
            ppr_perc,
            appinputs,
            dataset_file,
            appname,
            tags,
        )

    taskset_handler.update_task_status(task["id"], tasks_file, task_status)

    batch_handler.delete_pool(poolname)
    batch_handler.delete_job(jobname)