ConflixIQStudio/schema.js at main · amishra213/ConflixIQStudio · 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
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
import gql from 'graphql-tag';

const typeDefs = gql`
  scalar JSON

  type Query {
    workflows(limit: Int, offset: Int): [Workflow]
    workflow(name: String!, version: Int): Workflow
    workflowExecutions(workflowName: String!, limit: Int): [WorkflowExecution]
    taskDefinitions: [TaskDefinition]
    searchWorkflows(query: String!, limit: Int): [WorkflowExecution]
  }

  type Mutation {
    createWorkflow(workflow: WorkflowInput!): WorkflowResponse
    updateWorkflow(workflow: WorkflowInput!): WorkflowResponse
    saveWorkflow(workflow: WorkflowInput!): WorkflowResponse
    startWorkflow(name: String!, version: Int, input: JSON): StartWorkflowResponse
    terminateWorkflow(workflowId: String!, reason: String): SuccessResponse
    restartWorkflow(workflowId: String!): StartWorkflowResponse
    pauseWorkflow(workflowId: String!): SuccessResponse
    resumeWorkflow(workflowId: String!): SuccessResponse
    registerTask(task: TaskDefinitionInput!): TaskDefinitionResponse
    updateTask(task: TaskDefinitionInput!): TaskDefinitionResponse
    deleteTask(taskName: String!): SuccessResponse
  }

  type Workflow {
    name: String!
    description: String
    version: Int
    createTime: String
    updateTime: String
    createdBy: String
    updatedBy: String
    ownerEmail: String
    ownerApp: String
    timeoutSeconds: Int
    timeoutPolicy: String
    tasks: [WorkflowTask]
    inputParameters: [String]
    inputTemplate: JSON
    outputParameters: JSON
    restartable: Boolean
    schemaVersion: Int
    accessPolicy: JSON
    failureWorkflow: String
    variables: JSON
    workflowStatusListenerEnabled: Boolean
    effectiveDate: String
    endDate: String
    status: String
  }

  type WorkflowTask {
    name: String
    taskReferenceName: String
    type: String
    workflowTaskType: String
    description: String
    inputParameters: JSON
    outputParameters: JSON
    optional: Boolean
    asyncComplete: Boolean
    retryCount: Int
    startDelay: Int
    rateLimited: Boolean
    evaluatorType: String
    expression: String
    scriptExpression: String
    decisionCases: JSON
    defaultCase: JSON
    forkTasks: JSON
    joinOn: [String]
    defaultExclusiveJoinTask: [String]
    loopCondition: String
    loopOver: JSON
    dynamicForkTasksParam: String
    dynamicForkTasksInputParamName: String
    dynamicTaskNameParam: String
    sink: String
    subWorkflowParam: JSON
    taskDefinition: TaskDefinitionFull
  }

  type WorkflowExecution {
    workflowId: String
    workflowName: String
    status: String
    startTime: String
    endTime: String
    input: JSON
    output: JSON
    tasks: [TaskExecution]
    version: Int
  }

  type TaskExecution {
    taskId: String
    taskType: String
    status: String
    startTime: String
    endTime: String
    input: JSON
    output: JSON
  }

  type TaskDefinition {
    name: String
    description: String
    createdBy: String
    updatedBy: String
    createTime: String
    updateTime: String
    ownerEmail: String
    ownerApp: String
    retryCount: Int
    retryDelaySeconds: Int
    retryLogic: String
    timeoutSeconds: Int
    timeoutPolicy: String
    responseTimeoutSeconds: Int
    pollTimeoutSeconds: Int
    backoffScaleFactor: Float
    concurrentExecLimit: Int
    rateLimitPerFrequency: Int
    rateLimitFrequencyInSeconds: Int
    inputKeys: [String]
    outputKeys: [String]
    inputTemplate: JSON
    isolationGroupId: String
    executionNameSpace: String
    accessPolicy: JSON
  }

  type TaskDefinitionFull {
    name: String
    description: String
    createdBy: String
    updatedBy: String
    createTime: String
    updateTime: String
    ownerEmail: String
    ownerApp: String
    retryCount: Int
    retryDelaySeconds: Int
    retryLogic: String
    timeoutSeconds: Int
    timeoutPolicy: String
    responseTimeoutSeconds: Int
    pollTimeoutSeconds: Int
    backoffScaleFactor: Float
    concurrentExecLimit: Int
    rateLimitPerFrequency: Int
    rateLimitFrequencyInSeconds: Int
    inputKeys: [String]
    outputKeys: [String]
    inputTemplate: JSON
    isolationGroupId: String
    executionNameSpace: String
    accessPolicy: JSON
  }

  input WorkflowInput {
    name: String!
    description: String
    version: Int
    createdBy: String
    updatedBy: String
    ownerEmail: String
    ownerApp: String
    createTime: String
    updateTime: String
    tasks: [WorkflowTaskInput]
    inputParameters: [String]
    inputTemplate: JSON
    outputParameters: JSON
    timeoutSeconds: Int
    timeoutPolicy: String
    restartable: Boolean
    schemaVersion: Int
    accessPolicy: JSON
    failureWorkflow: String
    variables: JSON
    workflowStatusListenerEnabled: Boolean
    effectiveDate: String
    endDate: String
    status: String
  }

  input WorkflowTaskInput {
    name: String
    taskReferenceName: String
    type: String
    workflowTaskType: String
    description: String
    inputParameters: JSON
    outputParameters: JSON
    optional: Boolean
    asyncComplete: Boolean
    retryCount: Int
    startDelay: Int
    rateLimited: Boolean
    evaluatorType: String
    expression: String
    scriptExpression: String
    decisionCases: JSON
    defaultCase: JSON
    forkTasks: JSON
    joinOn: [String]
    defaultExclusiveJoinTask: [String]
    loopCondition: String
    loopOver: JSON
    dynamicForkTasksParam: String
    dynamicForkTasksInputParamName: String
    dynamicTaskNameParam: String
    sink: String
    subWorkflowParam: JSON
    taskDefinition: TaskDefinitionInputFull
  }

  input TaskDefinitionInput {
    name: String!
    description: String
    createdBy: String
    updatedBy: String
    createTime: String
    updateTime: String
    ownerEmail: String
    ownerApp: String
    retryCount: Int
    retryDelaySeconds: Int
    retryLogic: String
    timeoutSeconds: Int
    timeoutPolicy: String
    responseTimeoutSeconds: Int
    pollTimeoutSeconds: Int
    backoffScaleFactor: Float
    concurrentExecLimit: Int
    rateLimitPerFrequency: Int
    rateLimitFrequencyInSeconds: Int
    inputKeys: [String]
    outputKeys: [String]
    inputTemplate: JSON
    isolationGroupId: String
    executionNameSpace: String
    accessPolicy: JSON
  }

  input TaskDefinitionInputFull {
    name: String!
    description: String
    createdBy: String
    updatedBy: String
    createTime: String
    updateTime: String
    ownerEmail: String
    ownerApp: String
    retryCount: Int
    retryDelaySeconds: Int
    retryLogic: String
    timeoutSeconds: Int
    timeoutPolicy: String
    responseTimeoutSeconds: Int
    pollTimeoutSeconds: Int
    backoffScaleFactor: Float
    concurrentExecLimit: Int
    rateLimitPerFrequency: Int
    rateLimitFrequencyInSeconds: Int
    inputKeys: [String]
    outputKeys: [String]
    inputTemplate: JSON
    isolationGroupId: String
    executionNameSpace: String
    accessPolicy: JSON
  }

  type WorkflowResponse {
    name: String
    version: Int
    success: Boolean
    error: String
    errorDetails: String
    errorCode: String
    errorSeverity: String
  }

  type StartWorkflowResponse {
    workflowId: String
  }

  type SuccessResponse {
    success: Boolean
  }

  type TaskDefinitionResponse {
    name: String
  }
`;

export default typeDefs;