Creates a Cloud Dataflow job from a template.
This method waits—the workflow execution is paused—until the operation is
complete, fails, or times out. The default timeout value is 1800
seconds (30
minutes) and can be changed to a maximum value of 31536000
seconds (one year)
for long-running operations using the connector_params
field. See the Connectors reference
.
The connector uses polling to monitor the long-running operation, which might generate additional billable steps. For more information about retries and long-running operations, refer to Understand connectors .
The polling policy for the long-running operation can be configured. To set the
connector-specific parameters ( connector_params
), refer to Invoke a connector call
.
Arguments
projectId
string
Required. The ID of the Cloud Platform project that the job belongs to.
body
object ( CreateJobFromTemplateRequest
)
Required.
Raised exceptions
ConnectionError
HttpError
TimeoutError
TypeError
ValueError
OperationError
ResponseTypeError
Response
If successful, the response contains an instance of Job
.
Subworkflow snippet
Some fields might be optional or required. To identify required fields, refer to the API documentation .
YAML
- create : call : googleapis.dataflow.v1b3.projects.templates.create args : projectId : ... body : environment : additionalExperiments : ... additionalUserLabels : ... bypassTempDirValidation : ... enableStreamingEngine : ... ipConfiguration : ... kmsKeyName : ... machineType : ... maxWorkers : ... network : ... numWorkers : ... serviceAccountEmail : ... subnetwork : ... tempLocation : ... workerRegion : ... workerZone : ... zone : ... gcsPath : ... jobName : ... location : ... parameters : ... result : createResult
JSON
[ { "create" : { "call" : "googleapis.dataflow.v1b3.projects.templates.create" , "args" : { "projectId" : "..." , "body" : { "environment" : { "additionalExperiments" : "..." , "additionalUserLabels" : "..." , "bypassTempDirValidation" : "..." , "enableStreamingEngine" : "..." , "ipConfiguration" : "..." , "kmsKeyName" : "..." , "machineType" : "..." , "maxWorkers" : "..." , "network" : "..." , "numWorkers" : "..." , "serviceAccountEmail" : "..." , "subnetwork" : "..." , "tempLocation" : "..." , "workerRegion" : "..." , "workerZone" : "..." , "zone" : "..." }, "gcsPath" : "..." , "jobName" : "..." , "location" : "..." , "parameters" : "..." } }, "result" : "createResult" } } ]
