work_items

Creates, updates, deletes, gets or lists a work_items resource.

Overview

Name	work_items
Type	Resource
Id	google.dataflow.work_items

Fields

The following fields are returned by SELECT queries:

SELECT not supported for this resource, use SHOW METHODS to view available operations for the resource.

Methods

The following methods are available for this resource:

Name	Accessible by	Required Params	Optional Params	Description
projects_jobs_work_items_report_status	exec	projectId, jobId		Reports the status of dataflow WorkItems leased by a worker.
projects_jobs_work_items_lease	exec	projectId, jobId		Leases a dataflow WorkItem to run.
projects_locations_jobs_work_items_report_status	exec	projectId, location, jobId		Reports the status of dataflow WorkItems leased by a worker.
projects_locations_jobs_work_items_lease	exec	projectId, location, jobId		Leases a dataflow WorkItem to run.

Parameters

Parameters can be passed in the WHERE clause of a query. Check the Methods section to see which parameters are required or optional for each operation.

Name	Datatype	Description
jobId	string
location	string
projectId	string

Lifecycle Methods

projects_jobs_work_items_report_status

Reports the status of dataflow WorkItems leased by a worker.

EXEC google.dataflow.work_items.projects_jobs_work_items_report_status 
@projectId='{{ projectId }}' --required, 
@jobId='{{ jobId }}' --required 
@@json=
'{
"workerId": "{{ workerId }}", 
"workItemStatuses": "{{ workItemStatuses }}", 
"currentWorkerTime": "{{ currentWorkerTime }}", 
"location": "{{ location }}", 
"unifiedWorkerRequest": "{{ unifiedWorkerRequest }}", 
"projectNumber": "{{ projectNumber }}"
}';

projects_jobs_work_items_lease

Leases a dataflow WorkItem to run.

EXEC google.dataflow.work_items.projects_jobs_work_items_lease 
@projectId='{{ projectId }}' --required, 
@jobId='{{ jobId }}' --required 
@@json=
'{
"workItemTypes": "{{ workItemTypes }}", 
"workerCapabilities": "{{ workerCapabilities }}", 
"requestedLeaseDuration": "{{ requestedLeaseDuration }}", 
"currentWorkerTime": "{{ currentWorkerTime }}", 
"workerId": "{{ workerId }}", 
"location": "{{ location }}", 
"unifiedWorkerRequest": "{{ unifiedWorkerRequest }}", 
"projectNumber": "{{ projectNumber }}"
}';

projects_locations_jobs_work_items_report_status

Reports the status of dataflow WorkItems leased by a worker.

EXEC google.dataflow.work_items.projects_locations_jobs_work_items_report_status 
@projectId='{{ projectId }}' --required, 
@location='{{ location }}' --required, 
@jobId='{{ jobId }}' --required 
@@json=
'{
"workerId": "{{ workerId }}", 
"workItemStatuses": "{{ workItemStatuses }}", 
"currentWorkerTime": "{{ currentWorkerTime }}", 
"location": "{{ location }}", 
"unifiedWorkerRequest": "{{ unifiedWorkerRequest }}", 
"projectNumber": "{{ projectNumber }}"
}';

projects_locations_jobs_work_items_lease

Leases a dataflow WorkItem to run.

EXEC google.dataflow.work_items.projects_locations_jobs_work_items_lease 
@projectId='{{ projectId }}' --required, 
@location='{{ location }}' --required, 
@jobId='{{ jobId }}' --required 
@@json=
'{
"workItemTypes": "{{ workItemTypes }}", 
"workerCapabilities": "{{ workerCapabilities }}", 
"requestedLeaseDuration": "{{ requestedLeaseDuration }}", 
"currentWorkerTime": "{{ currentWorkerTime }}", 
"workerId": "{{ workerId }}", 
"location": "{{ location }}", 
"unifiedWorkerRequest": "{{ unifiedWorkerRequest }}", 
"projectNumber": "{{ projectNumber }}"
}';