app_service/AppService.spec at master · PATRIC3/app_service · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
module AppService
{
    authentication required;

    typedef string task_id;
    typedef string app_id;
    typedef string workspace_id;

    typedef mapping<string, string> task_parameters;

    typedef structure {
	string id;
	string label;
	int required;
	string default;
	string desc;
	string type;
	string enum;
	string wstype;
    } AppParameter;

    typedef structure {
	app_id id;
	string script;
	string label;
	string description;
	list<AppParameter> parameters;
    } App;

    typedef string task_status;

    typedef structure {
	task_id id;
	task_id parent_id;
	app_id app;
	workspace_id workspace;
	task_parameters parameters;
	string user_id;

	task_status status;
	task_status awe_status;
	string submit_time;
	string start_time;
	string completed_time;

	string stdout_shock_node;
	string stderr_shock_node;

    } Task;

    typedef structure {
	task_id id;
	App app;
	task_parameters parameters;
	float start_time;
	float end_time;
	float elapsed_time;
	string hostname;
	list <tuple<string output_path, string output_id>> output_files;
    } TaskResult;

    funcdef service_status() returns (tuple<int submission_enabled, string status_message>);

    funcdef enumerate_apps()
	returns (list<App>);

    funcdef start_app(app_id, task_parameters params, workspace_id workspace)
	returns (Task task);

    typedef structure {
        task_id parent_id;
	workspace_id workspace;
    } StartParams;
    funcdef start_app2(app_id, task_parameters params, StartParams start_params)
	returns (Task task);

    funcdef query_tasks(list<task_id> task_ids)
	returns (mapping<task_id, Task task> tasks);

    funcdef query_task_summary() returns (mapping<task_status status, int count> status);

    typedef structure {
	string stdout_url;
	string stderr_url;
	int pid;
	string hostname;
	int exitcode;
    } TaskDetails;
    funcdef query_task_details(task_id) returns (TaskDetails details);

    funcdef enumerate_tasks(int offset, int count)
	returns (list<Task>);

    funcdef kill_task(task_id id) returns (int killed, string msg);
    funcdef rerun_task(task_id id) returns (task_id new_task);
};