You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
<pclass="firstline">Re-execute an existing execution, with same request parameters and execution strategy</p>
97
100
<h3>Method Details</h3>
98
101
<divclass="method">
99
102
<codeclass="details" id="close">close()</code>
@@ -150,8 +153,9 @@ <h3>Method Details</h3>
150
153
},
151
154
],
152
155
"eventExecutionSnapshot": [
153
-
{ # Contains the snapshot of the event execution for a given checkpoint. Next available id: 13
156
+
{ # Contains the snapshot of the event execution for a given checkpoint. Next available id: 15
154
157
"checkpointTaskNumber": "A String", # Indicates "right after which checkpoint task's execution" this snapshot is taken.
158
+
"clientId": "A String", # Client that the execution snapshot is associated to.
155
159
"conditionResults": [ # All of the computed conditions that been calculated.
156
160
{ # Contains the combined condition calculation results.
157
161
"currentTaskNumber": "A String", # the current task number.
@@ -284,6 +288,7 @@ <h3>Method Details</h3>
284
288
},
285
289
],
286
290
"taskName": "A String", # The task name associated with this snapshot. Could be empty.
291
+
"workflowName": "A String", # Name of the workflow this event execution snapshot belongs to.
287
292
},
288
293
],
289
294
"eventExecutionSnapshotsSize": "A String", # Total size of all event_execution_snapshots for an execution
@@ -883,8 +888,9 @@ <h3>Method Details</h3>
883
888
},
884
889
],
885
890
"eventExecutionSnapshot": [
886
-
{ # Contains the snapshot of the event execution for a given checkpoint. Next available id: 13
891
+
{ # Contains the snapshot of the event execution for a given checkpoint. Next available id: 15
887
892
"checkpointTaskNumber": "A String", # Indicates "right after which checkpoint task's execution" this snapshot is taken.
893
+
"clientId": "A String", # Client that the execution snapshot is associated to.
888
894
"conditionResults": [ # All of the computed conditions that been calculated.
889
895
{ # Contains the combined condition calculation results.
890
896
"currentTaskNumber": "A String", # the current task number.
@@ -1017,6 +1023,7 @@ <h3>Method Details</h3>
1017
1023
},
1018
1024
],
1019
1025
"taskName": "A String", # The task name associated with this snapshot. Could be empty.
1026
+
"workflowName": "A String", # Name of the workflow this event execution snapshot belongs to.
1020
1027
},
1021
1028
],
1022
1029
"eventExecutionSnapshotsSize": "A String", # Total size of all event_execution_snapshots for an execution
<pre>Re-execute an existing execution, with same request parameters and execution strategy
1295
+
1296
+
Args:
1297
+
name: string, Required. The execution resource name. Format: projects/{gcp_project_id}/locations/{location}/integrations/{integration}/executions/{execution_id} (required)
1298
+
body: object, The request body.
1299
+
The object takes the form of:
1300
+
1301
+
{ # Request for replaying an execution Next ID: 3
1302
+
"replayReason": "A String", # Optional. The user provided reason for replaying the execution.
1303
+
}
1304
+
1305
+
x__xgafv: string, V1 error format.
1306
+
Allowed values
1307
+
1 - v1 error format
1308
+
2 - v2 error format
1309
+
1310
+
Returns:
1311
+
An object of the form:
1312
+
1313
+
{ # Response for replaying an execution Next ID: 4
1314
+
"executionId": "A String", # The id of the execution corresponding to this run of integration.
1315
+
"outputParameters": { # OUTPUT parameters in format of Map. Where Key is the name of the parameter. The parameters would only be present in case of synchrounous execution Note: Name of the system generated parameters are wrapped by backtick(`) to distinguish them from the user defined parameters.
1316
+
"a_key": "", # Properties of the object.
1317
+
},
1318
+
"replayedExecutionId": "A String", # The execution id which is replayed
Copy file name to clipboardExpand all lines: docs/dyn/integrations_v1.projects.locations.integrations.html
+32Lines changed: 32 additions & 0 deletions
Original file line number
Diff line number
Diff line change
@@ -928,6 +928,22 @@ <h3>Method Details</h3>
928
928
"status": "A String", # Output only. Generated by eventbus. User should not set it as an input.
929
929
"taskConfigs": [ # Optional. Task configuration for the integration. It's optional, but the integration doesn't do anything without task_configs.
930
930
{ # The task configuration details. This is not the implementation of Task. There might be multiple TaskConfigs for the same Task.
931
+
"conditionalFailurePolicies": { # Conditional task failur retry strategies # Optional. The list of conditional failure policies that will be applied to the task in order.
932
+
"defaultFailurePolicy": { # Policy that defines the task retry logic and failure type. If no FailurePolicy is defined for a task, all its dependent tasks will not be executed (i.e, a `retry_strategy` of NONE will be applied). # The default failure policy to be applied if no conditional failure policy matches.
933
+
"condition": "A String", # Optional. The string condition that will be evaluated to determine if the task should be retried with this failure policy.
934
+
"intervalTime": "A String", # Required if retry_strategy is FIXED_INTERVAL or LINEAR/EXPONENTIAL_BACKOFF/RESTART_INTEGRATION_WITH_BACKOFF. Defines the initial interval in seconds for backoff.
935
+
"maxRetries": 42, # Required if retry_strategy is FIXED_INTERVAL or LINEAR/EXPONENTIAL_BACKOFF/RESTART_INTEGRATION_WITH_BACKOFF. Defines the number of times the task will be retried if failed.
936
+
"retryStrategy": "A String", # Defines what happens to the task upon failure.
937
+
},
938
+
"failurePolicies": [ # The list of failure policies that will be applied to the task in order.
939
+
{ # Policy that defines the task retry logic and failure type. If no FailurePolicy is defined for a task, all its dependent tasks will not be executed (i.e, a `retry_strategy` of NONE will be applied).
940
+
"condition": "A String", # Optional. The string condition that will be evaluated to determine if the task should be retried with this failure policy.
941
+
"intervalTime": "A String", # Required if retry_strategy is FIXED_INTERVAL or LINEAR/EXPONENTIAL_BACKOFF/RESTART_INTEGRATION_WITH_BACKOFF. Defines the initial interval in seconds for backoff.
942
+
"maxRetries": 42, # Required if retry_strategy is FIXED_INTERVAL or LINEAR/EXPONENTIAL_BACKOFF/RESTART_INTEGRATION_WITH_BACKOFF. Defines the number of times the task will be retried if failed.
943
+
"retryStrategy": "A String", # Defines what happens to the task upon failure.
944
+
},
945
+
],
946
+
},
931
947
"description": "A String", # Optional. User-provided description intended to give additional business context about the task.
932
948
"displayName": "A String", # Optional. User-provided label that is attached to this TaskConfig in the UI.
933
949
"errorCatcherId": "A String", # Optional. Optional Error catcher id of the error catch flow which will be executed when execution error happens in the task
@@ -1033,6 +1049,22 @@ <h3>Method Details</h3>
1033
1049
},
1034
1050
},
1035
1051
],
1052
+
"conditionalFailurePolicies": { # Optional. Determines the number of times the task will be retried on failure and with what retry strategy. This is applicable for synchronous calls to Eventbus alone (Post).
1053
+
"defaultFailurePolicy": { # Policy that defines the task retry logic and failure type. If no FailurePolicy is defined for a task, all its dependent tasks will not be executed (i.e, a `retry_strategy` of NONE will be applied). # The default failure policy to be applied if no conditional failure policy matches
1054
+
"intervalInSeconds": "A String", # Required if retry_strategy is FIXED_INTERVAL or LINEAR/EXPONENTIAL_BACKOFF/RESTART_WORKFLOW_WITH_BACKOFF. Defines the initial interval for backoff.
1055
+
"maxNumRetries": 42, # Required if retry_strategy is FIXED_INTERVAL or LINEAR/EXPONENTIAL_BACKOFF/RESTART_WORKFLOW_WITH_BACKOFF. Defines the number of times the task will be retried if failed.
1056
+
"retryCondition": "A String", # Optional. The retry condition that will be evaluated for this failure policy with the corresponding retry strategy.
1057
+
"retryStrategy": "A String", # Defines what happens to the task upon failure.
1058
+
},
1059
+
"failurePolicies": [ # The list of failure policies that will be applied to the task in order.
1060
+
{ # Policy that defines the task retry logic and failure type. If no FailurePolicy is defined for a task, all its dependent tasks will not be executed (i.e, a `retry_strategy` of NONE will be applied).
1061
+
"intervalInSeconds": "A String", # Required if retry_strategy is FIXED_INTERVAL or LINEAR/EXPONENTIAL_BACKOFF/RESTART_WORKFLOW_WITH_BACKOFF. Defines the initial interval for backoff.
1062
+
"maxNumRetries": 42, # Required if retry_strategy is FIXED_INTERVAL or LINEAR/EXPONENTIAL_BACKOFF/RESTART_WORKFLOW_WITH_BACKOFF. Defines the number of times the task will be retried if failed.
1063
+
"retryCondition": "A String", # Optional. The retry condition that will be evaluated for this failure policy with the corresponding retry strategy.
1064
+
"retryStrategy": "A String", # Defines what happens to the task upon failure.
0 commit comments