create method

Future<GoogleCloudDatapipelinesV1Pipeline> create(
  1. GoogleCloudDatapipelinesV1Pipeline request,
  2. String parent, {
  3. String? $fields,
})

Creates a pipeline.

For a batch pipeline, you can pass scheduler information. Data Pipelines uses the scheduler information to create an internal scheduler that runs jobs periodically. If the internal scheduler is not configured, you can use RunPipeline to run jobs.

request - The metadata request object.

Request parameters:

parent - Required. The location name. For example: projects/PROJECT_ID/locations/LOCATION_ID. Value must have pattern ^projects/\[^/\]+/locations/\[^/\]+$.

$fields - Selector specifying which fields to include in a partial response.

Completes with a GoogleCloudDatapipelinesV1Pipeline.

Completes with a commons.ApiRequestError if the API endpoint returned an error.

If the used http.Client completes with an error when making a REST call, this method will complete with the same error.

Implementation

async.Future<GoogleCloudDatapipelinesV1Pipeline> create(
  GoogleCloudDatapipelinesV1Pipeline request,
  core.String parent, {
  core.String? $fields,
}) async {
  final body_ = convert.json.encode(request);
  final queryParams_ = <core.String, core.List<core.String>>{
    if ($fields != null) 'fields': [$fields],
  };

  final url_ = 'v1/' + core.Uri.encodeFull('$parent') + '/pipelines';

  final response_ = await _requester.request(
    url_,
    'POST',
    body: body_,
    queryParams: queryParams_,
  );
  return GoogleCloudDatapipelinesV1Pipeline.fromJson(
      response_ as core.Map<core.String, core.dynamic>);
}