batch_task.h

/*
Copyright (C) 2018- The University of Notre Dame
This software is distributed under the GNU General Public License.
See the file COPYING for details.
*/

#ifndef BATCH_TASK_H
#define BATCH_TASK_H

#include "batch_file.h"
#include "list.h"
#include "sha1.h"
#include "jx.h"
#include "rmsummary.h"

struct batch_task {
        int taskid;                  /* Indicates the id provided by the creating system. I.E. Makeflow */
        int jobid;                   /* Indicates the id assigned to the job by the submission system. */

        struct batch_queue *queue;   /* The queue this task is assigned to. */

        char *command;               /* The command line to execute. */

        struct list   *input_files;  /* Task's required inputs, type batch_file */
        struct list   *output_files; /* Task's expected outputs, type batch_file */

        struct rmsummary *resources; /* Resources assigned to task */

        struct jx *envlist;          /* JSON formatted environment list */ 

        struct batch_job_info *info; /* Stores the info struct created by batch_job. */

        char *hash;                  /* Checksum based on CMD, input contents, and output names. */
};

struct batch_task *batch_task_create(struct batch_queue *queue );

void batch_task_delete(struct batch_task *t);

struct batch_file * batch_task_add_input_file(struct batch_task *task, const char * outer_name, const char * inner_name);

struct batch_file * batch_task_add_output_file(struct batch_task *task, const char * outer_name, const char * inner_name);

void batch_task_set_command(struct batch_task *t, const char *command);

void batch_task_set_command_spec(struct batch_task *t, struct jx *command);

void batch_task_wrap_command(struct batch_task *t, const char *command);

void batch_task_set_resources(struct batch_task *t, const struct rmsummary *resources);

void batch_task_set_envlist(struct batch_task *t, struct jx *envlist);

void batch_task_set_info(struct batch_task *t, struct batch_job_info *info);

char * batch_task_generate_id(struct batch_task *t);

#endif
/* vim: set noexpandtab tabstop=4: */