resumeWorkflowRun method

Future<ResumeWorkflowRunResponse> resumeWorkflowRun({ required String name, required List<String> nodeIds, required String runId, })

Restarts selected nodes of a previous partially completed workflow run and resumes the workflow run. The selected nodes and all nodes that are downstream from the selected nodes are run.

May throw InvalidInputException. May throw EntityNotFoundException. May throw InternalServiceException. May throw OperationTimeoutException. May throw ConcurrentRunsExceededException. May throw IllegalWorkflowStateException.

Parameter name : The name of the workflow to resume.

Parameter nodeIds : A list of the node IDs for the nodes you want to restart. The nodes that are to be restarted must have a run attempt in the original run.

Parameter runId : The ID of the workflow run to resume.

Implementation

Future<ResumeWorkflowRunResponse> resumeWorkflowRun({
  required String name,
  required List<String> nodeIds,
  required String runId,
}) async {
  ArgumentError.checkNotNull(name, 'name');
  _s.validateStringLength(
    'name',
    name,
    1,
    255,
    isRequired: true,
  );
  ArgumentError.checkNotNull(nodeIds, 'nodeIds');
  ArgumentError.checkNotNull(runId, 'runId');
  _s.validateStringLength(
    'runId',
    runId,
    1,
    255,
    isRequired: true,
  );
  final headers = <String, String>{
    'Content-Type': 'application/x-amz-json-1.1',
    'X-Amz-Target': 'AWSGlue.ResumeWorkflowRun'
  };
  final jsonResponse = await _protocol.send(
    method: 'POST',
    requestUri: '/',
    exceptionFnMap: _exceptionFns,
    // TODO queryParams
    headers: headers,
    payload: {
      'Name': name,
      'NodeIds': nodeIds,
      'RunId': runId,
    },
  );

  return ResumeWorkflowRunResponse.fromJson(jsonResponse.body);
}