Pipeline Run - Query Pipeline Runs By Workspace

Reference

Service:: Synapse

API Version:: 2020-12-01

Query pipeline runs in the workspace based on input filter conditions.

POST {endpoint}/queryPipelineRuns?api-version=2020-12-01

URI Parameters

Name	In	Required	Type	Description
endpoint	path	True	string uri	The workspace development endpoint, for example `https://myworkspace.dev.azuresynapse.net`.
api-version	query	True	string	The Synapse client API Version.

Request Body

Name	Required	Type	Description
lastUpdatedAfter	True	string	The time at or after which the run event was updated in 'ISO 8601' format.
lastUpdatedBefore	True	string	The time at or before which the run event was updated in 'ISO 8601' format.
continuationToken		string	The continuation token for getting the next page of results. Null for first page.
filters		RunQueryFilter[]	List of filters.
orderBy		RunQueryOrderBy[]	List of OrderBy option.

Responses

Name	Type	Description
200 OK	PipelineRunsQueryResponse	OK.
Other Status Codes	CloudError	An error response received from the Azure Synapse service.

Examples

PipelineRuns_QueryByWorkspace

Sample request

HTTP

POST exampleWorkspace.dev.azuresynapse.net/queryPipelineRuns?api-version=2020-12-01

{
  "lastUpdatedAfter": "2018-06-16T00:36:44.3345758Z",
  "lastUpdatedBefore": "2018-06-16T00:49:48.3686473Z",
  "filters": [
    {
      "operand": "PipelineName",
      "operator": "Equals",
      "values": [
        "examplePipeline"
      ]
    }
  ]
}

Sample response

Status code:: 200

Date: Sat, 16 Jun 2018 00:40:01 GMT
X-Content-Type-Options: nosniff
x-ms-ratelimit-remaining-subscription-reads: 14989
x-ms-request-id: 2f955e10-c6df-45a7-97d4-81acdb8540cd
x-ms-correlation-request-id: 2f955e10-c6df-45a7-97d4-81acdb8540cd

{
  "value": [
    {
      "runId": "2f7fdb90-5df1-4b8e-ac2f-064cfa58202b",
      "pipelineName": "examplePipeline",
      "parameters": {
        "OutputBlobNameList": "[\"exampleoutput.csv\"]"
      },
      "invokedBy": {
        "id": "80a01654a9d34ad18b3fcac5d5d76b67",
        "name": "Manual"
      },
      "runStart": "2018-06-16T00:37:44.6257014Z",
      "runEnd": "2018-06-16T00:38:12.7314495Z",
      "durationInMs": 28105,
      "status": "Succeeded",
      "message": "",
      "lastUpdated": "2018-06-16T00:38:12.7314495Z",
      "annotations": [],
      "runDimension": {
        "JobId": "79c1cc52-265f-41a5-9553-be65e736fbd3"
      }
    },
    {
      "runId": "16ac5348-ff82-4f95-a80d-638c1d47b721",
      "pipelineName": "examplePipeline",
      "parameters": {
        "OutputBlobNameList": "[\"exampleoutput.csv\"]"
      },
      "invokedBy": {
        "id": "7c5fd7ef7e8a464b98b931cf15fcac66",
        "name": "Manual"
      },
      "runStart": "2018-06-16T00:39:49.2745128Z",
      "runEnd": null,
      "durationInMs": null,
      "status": "Cancelled",
      "message": "",
      "lastUpdated": "2018-06-16T00:39:51.216097Z",
      "annotations": [],
      "runDimension": {
        "JobId": "84a3c493-0628-4b44-852f-ef5b3a11bdab"
      }
    }
  ]
}

Definitions

Name	Description
CloudError	The object that defines the structure of an Azure Synapse error response.
PipelineRun	Information about a pipeline run.
PipelineRunInvokedBy	Provides entity name and id that started the pipeline run.
PipelineRunsQueryResponse	A list pipeline runs.
RunFilterParameters	Query parameters for listing runs.
RunQueryFilter	Query filter option for listing runs.
RunQueryFilterOperand	Parameter name to be used for filter. The allowed operands to query pipeline runs are PipelineName, RunStart, RunEnd and Status; to query activity runs are ActivityName, ActivityRunStart, ActivityRunEnd, ActivityType and Status, and to query trigger runs are TriggerName, TriggerRunTimestamp and Status.
RunQueryFilterOperator	Operator to be used for filter.
RunQueryOrder	Sorting order of the parameter.
RunQueryOrderBy	An object to provide order by options for listing runs.
RunQueryOrderByField	Parameter name to be used for order by. The allowed parameters to order by for pipeline runs are PipelineName, RunStart, RunEnd and Status; for activity runs are ActivityName, ActivityRunStart, ActivityRunEnd and Status; for trigger runs are TriggerName, TriggerRunTimestamp and Status.

CloudError

The object that defines the structure of an Azure Synapse error response.

Name	Type	Description
error.code	string	Error code.
error.details	CloudError[]	Array with additional error details.
error.message	string	Error message.
error.target	string	Property name/path in request associated with error.

PipelineRun

Information about a pipeline run.

Name	Type	Description
durationInMs	integer	The duration of a pipeline run.
invokedBy	PipelineRunInvokedBy	Entity that started the pipeline run.
isLatest	boolean	Indicates if the recovered pipeline run is the latest in its group.
lastUpdated	string	The last updated timestamp for the pipeline run event in ISO8601 format.
message	string	The message from a pipeline run.
parameters	object	The full or partial list of parameter name, value pair used in the pipeline run.
pipelineName	string	The pipeline name.
runEnd	string	The end time of a pipeline run in ISO8601 format.
runGroupId	string	Identifier that correlates all the recovery runs of a pipeline run.
runId	string	Identifier of a run.
runStart	string	The start time of a pipeline run in ISO8601 format.
status	string	The status of a pipeline run.

PipelineRunInvokedBy

Provides entity name and id that started the pipeline run.

Name	Type	Description
id	string	The ID of the entity that started the run.
invokedByType	string	The type of the entity that started the run.
name	string	Name of the entity that started the pipeline run.

PipelineRunsQueryResponse

A list pipeline runs.

Name	Type	Description
continuationToken	string	The continuation token for getting the next page of results, if any remaining results exist, null otherwise.
value	PipelineRun[]	List of pipeline runs.

RunFilterParameters

Query parameters for listing runs.

Name	Type	Description
continuationToken	string	The continuation token for getting the next page of results. Null for first page.
filters	RunQueryFilter[]	List of filters.
lastUpdatedAfter	string	The time at or after which the run event was updated in 'ISO 8601' format.
lastUpdatedBefore	string	The time at or before which the run event was updated in 'ISO 8601' format.
orderBy	RunQueryOrderBy[]	List of OrderBy option.

RunQueryFilter

Query filter option for listing runs.

Name	Type	Description
operand	RunQueryFilterOperand	Parameter name to be used for filter. The allowed operands to query pipeline runs are PipelineName, RunStart, RunEnd and Status; to query activity runs are ActivityName, ActivityRunStart, ActivityRunEnd, ActivityType and Status, and to query trigger runs are TriggerName, TriggerRunTimestamp and Status.
operator	RunQueryFilterOperator	Operator to be used for filter.
values	string[]	List of filter values.

RunQueryFilterOperand

Parameter name to be used for filter. The allowed operands to query pipeline runs are PipelineName, RunStart, RunEnd and Status; to query activity runs are ActivityName, ActivityRunStart, ActivityRunEnd, ActivityType and Status, and to query trigger runs are TriggerName, TriggerRunTimestamp and Status.

Name	Type	Description
ActivityName	string
ActivityRunEnd	string
ActivityRunStart	string
ActivityType	string
LatestOnly	string
PipelineName	string
RunEnd	string
RunGroupId	string
RunStart	string
Status	string
TriggerName	string
TriggerRunTimestamp	string

RunQueryFilterOperator

Operator to be used for filter.

Name	Type	Description
Equals	string
In	string
NotEquals	string
NotIn	string

RunQueryOrder

Sorting order of the parameter.

Name	Type	Description
ASC	string
DESC	string

RunQueryOrderBy

An object to provide order by options for listing runs.

Name	Type	Description
order	RunQueryOrder	Sorting order of the parameter.
orderBy	RunQueryOrderByField	Parameter name to be used for order by. The allowed parameters to order by for pipeline runs are PipelineName, RunStart, RunEnd and Status; for activity runs are ActivityName, ActivityRunStart, ActivityRunEnd and Status; for trigger runs are TriggerName, TriggerRunTimestamp and Status.

RunQueryOrderByField

Parameter name to be used for order by. The allowed parameters to order by for pipeline runs are PipelineName, RunStart, RunEnd and Status; for activity runs are ActivityName, ActivityRunStart, ActivityRunEnd and Status; for trigger runs are TriggerName, TriggerRunTimestamp and Status.

Name	Type	Description
ActivityName	string
ActivityRunEnd	string
ActivityRunStart	string
PipelineName	string
RunEnd	string
RunStart	string
Status	string
TriggerName	string
TriggerRunTimestamp	string

Share via