Get Flow Instance¶
Get the information of a specified workflow instance.
Prerequisite¶
The user must be an EnOS user.
Request Format¶
GET https://{apigw-address}/dataflow-batch-service/v2.0/flowInstances
Request Parameters (URI)¶
| Name | Location (Path/Query) | Mandatory/Optional | Data Type | Description | 
|---|---|---|---|---|
| flowInstId | Query | Mandatory | String | The ID of the workflow instance. | 
| userId | Query | Mandatory | String | The user ID. How to get userId>> | 
| orgId | Query | Mandatory | String | The organization ID which the user belongs to. How to get orgId>> | 
| action | Query | Mandatory | String | Fixed value: get | 
Response Parameters¶
| Name | Data Type | Description | 
|---|---|---|
| data | FlowInstance Struct | The detailed information of the workflow instance. For more information, see FlowInstance Struct | 
FlowInstance Struct¶
Sample¶
{
    "instanceId": "2438-201907261239",
    "flowId": 2438,
    "flowName": "rew",
    "freq": "0 1/1 * * * ? *",
    "cycle": "mi",
    "parameters": "[]",
    "doAs": "yourDoAs",
    "graph": "{"creator":"yourCreator","freq":"0 1/1 * * * ? *","alertMode":3,"owners":";yourOwners;","cycle":"mi","doAs":"yourDoAs","flows":[],"alertTo":"","name":"rew","instId":"2438-201907261239","id":2438,"relations":[],"parameters":"[]","appId":"","tasks":[{"taskName":"fr","taskInstId":"104452-201907261239","x":0.0198,"y":0.0045,"taskId":104452,"nodeId":"t_104452","status":"SUCCESS"}]}",
    "status": 0,
    "statusDesc": "INIT",
    "triggerTime": "2019-07-26 20:39:00",
    "startTime": "2019-07-26 12:39:37",
    "endTime": "2019-07-26 12:39:42",
    "timestamp": "2019-07-26 12:38:30.0",
    "virtual": false,
    "owner": "yourOwners",
    "alertMode": 3,
    "calDt": "2019-07-25",
    "hasEditPri": false,
    "hasReadPri": true
}
Parameters¶
| Name | Data Type | Description | 
|---|---|---|
| instanceId | String | The ID of the workflow instance. | 
| flowId | Integer | The workflow ID. | 
| flowName | String | The workflow name. | 
| freq | String | If CronTab syntax is used when specifying the time to start the workflow in a scheduling cycle, a 7-character CronTab expression is used. For more information about CronTab, see the Cron Expression Explainer | 
| cycle | String | The scheduling cycle. 
 | 
| parameters | Map | The global parameters that are configured for the workflow to dynamically adapt to the environment changes (in the format of key=value). | 
| doAs | String | The big data account of the organization to which the workflow belongs. | 
| graph | InstanceGraph Struct | The task dependency of the workflow instance. For more information, see InstanceGraph Struct | 
| status | Integer | The task running status. | 
| statusDesc | String | The description of the task running status. | 
| triggerTime | String | The planned triggering time of the task. | 
| startTime | String | The start time of the task. | 
| endTime | String | The end time of the task. | 
| timestamp | String | The time when the instance was created. | 
| virtual | Boolean | 
 | 
| owner | String | The owner of the workflow instance. | 
| alertMode | Integer | The alert mode. 
 | 
| calDt | String | The business date (date from which the data starts to be processed by the workflow). | 
| hasEditPri | Boolean | 
 | 
| hasReadPri | Boolean | 
 | 
InstanceGraph Struct¶
Sample¶
{
  "creator":"yourCreator",
  "freq":"0 0 0 * * ? *",
  "alertMode":3,
  "owners":"yourOwners",
  "cycle":"D",
  "doAs":"yourDoAs",
  "flows":[],
  "alertTo":"",
  "name":"21",
  "instId":"2809-20190812080700",
  "id":2809,
  "relations":[],
  "parameters":"[]",
  "appId":"",
  "tasks":
      [{
      "taskName":"tass",
      "taskInstId":"104890-20190812080700",
      "x":0.002,
      "y":0.002,
      "taskId":104890,
      "nodeId":"t_104890",
      "status":"CANCEL"}]
}
Parameters¶
| Name | Data Type | Description | 
|---|---|---|
| creator | String | The username of the user who created the workflow instance. | 
| freq | String | If CronTab syntax is used when specifying the time to start the workflow in a scheduling cycle, a 7-character CronTab expression is used. For more information about CronTab, see the Cron Expression Explainer | 
| alertMode | Integer | The alert mode. 
 | 
| owners | String | The username of the owners of the workflow. The semicolon (;) is used to separate each owner, for example, owners=”userNameA;userNameB”. | 
| cycle | String | The scheduling cycle. 
 | 
| doAs | String | The big data account of the organization to which the workflow belongs. | 
| flows | Array of FlowInstanceGraph Struct | The workflow dependency of the workflow instance. For more information, see FlowInstanceGraph Struct | 
| alertTo | String | Receiver of alerts | 
| name | String | The workflow name. | 
| instId | Integer | The ID of the workflow instance. | 
| id | Integer | The workflow ID. | 
| relations | Array of Relation Structs | The list of relations between tasks in the workflow, with each element representing the upstream and downstream dependency. For more information, see Relation Struct | 
| parameters | Array | The parameters that are configured for the task to dynamically adapt to the environment changes (in the format of key=value) | 
| tasks | Array of TaskInstanceGraph Structs | The list of all task instances in the workflow instance. For more information, see TaskInstanceGraph Struct | 
FlowInstanceGraph Struct¶
Sample¶
{
  "flowId":"2809",
  "flowName":"21",
  "nodeId":"f_2809",
  "isVirtual":false,
  "x":0.0125,
  "y":0.0015,
  "flowInstId":"2809-20190812101300",
  "status":"NONE"
}
Parameters¶
| Name | Data Type | Description | 
|---|---|---|
| flowId | String | The workflow ID. | 
| flowName | String | The workflow name. | 
| nodeId | String | The ID of the node that is part of other workflows. | 
| isVirtual | Boolean | 
 | 
| x | Double | The x-axis of the node on the configuration panel of the workflow. | 
| y | Double | The y-axis of the node on the configuration panel of the workflow. | 
| flowInstId | String | The ID of the workflow instance. | 
TaskInstanceGraph Struct¶
Sample¶
{
  "taskName":"tass",
  "taskInstId":"105048-20190812101300",
    "x":0.0132,
    "y":0.008100000381469727,
    "taskId":"104575",
    "nodeId":"t_104575",
  "status":"INIT"
}
Parameters¶
| Name | Data Type | Description | 
|---|---|---|
| taskName | String | The task name. | 
| taskInstId | String | The ID of the task instance. | 
| x | Double | The x-axis of the task on the configuration panel. | 
| y | Double | The y-axis of the task on the configuration panel. | 
| taskId | String | The task ID. | 
| nodeId | String | The node ID (Note: The node ID is not the same as the task ID, because there are task nodes and workflow nodes that have dependency relations in a workflow). | 
| status | String | The status of the task instance. | 
Error Code¶
See Common Error Codes.
Samples¶
Request Sample¶
url: https://{apigw-address}/dataflow-batch-service/v2.0/flowInstances?action=get&flowInstId=2809-20190808093200&userId=yourUserId&orgId=yourOrgId
method: GET
Return Sample¶
{
  "status": 0,
  "msg": " Success",
  "data": {
    "instanceId": "2809-20190808093200",
    "flowId": 2809,
    "flowName": "21",
    "freq": "0 0 0 * * ? *",
    "cycle": "D",
    "parameters": "[]",
    "doAs": "yourDoAs",
    "graph": "{"creator":"yourCreator","freq":"0 0 0 * * ? *","alertMode":3,"owners":"yourOwners","cycle":"D","doAs":"yourDoAs","flows":[],"alertTo":"","name":"21","instId":"2809-20190808093200","id":2809,"relations":[],"parameters":"[]","appId":"","tasks":[{"taskName":"tass","taskInstId":"104890-20190808093200","x":0.002,"y":0.002,"taskId":104890,"nodeId":"t_104890","status":"SUCCESS"}]}",
    "status": 1,
    "statusDesc": "SUCCESS",
    "triggerTime": "2019-08-08 09:32:12",
    "startTime": "2019-08-08 09:32:30",
    "endTime": "2019-08-08 09:32:32",
    "timestamp": "2019-08-08 09:34:36.0",
    "virtual": false,
    "owner": "yourOwners",
    "alertMode": 3,
    "calDt": "2019-08-07",
    "hasEditPri": true,
    "hasReadPri": true
  }
}