The response to send back to the client (wrapped by a task).
CreateJob(CreateJobRequest, ServerCallContext)
public virtual Task<Job> CreateJob(CreateJobRequest request, ServerCallContext context)
Creates a Cloud Dataflow job.
To create a job, we recommend using projects.locations.jobs.create with a
regional endpoint. Using
projects.jobs.create is not recommended, as your job will always start
in us-central1.
The response to send back to the client (wrapped by a task).
GetJob(GetJobRequest, ServerCallContext)
public virtual Task<Job> GetJob(GetJobRequest request, ServerCallContext context)
Gets the state of the specified Cloud Dataflow job.
To get the state of a job, we recommend using projects.locations.jobs.get
with a regional endpoint. Using
projects.jobs.get is not recommended, as you can only get the state of
jobs that are running in us-central1.
The response to send back to the client (wrapped by a task).
ListJobs(ListJobsRequest, ServerCallContext)
public virtual Task<ListJobsResponse> ListJobs(ListJobsRequest request, ServerCallContext context)
List the jobs of a project.
To list the jobs of a project in a region, we recommend using
projects.locations.jobs.list with a regional endpoint. To
list the all jobs across all regions, use projects.jobs.aggregated. Using
projects.jobs.list is not recommended, as you can only get the list of
jobs that are running in us-central1.
The response to send back to the client (wrapped by a task).
UpdateJob(UpdateJobRequest, ServerCallContext)
public virtual Task<Job> UpdateJob(UpdateJobRequest request, ServerCallContext context)
Updates the state of an existing Cloud Dataflow job.
To update the state of an existing job, we recommend using
projects.locations.jobs.update with a regional endpoint. Using
projects.jobs.update is not recommended, as you can only update the state
of jobs that are running in us-central1.
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Missing the information I need","missingTheInformationINeed","thumb-down"],["Too complicated / too many steps","tooComplicatedTooManySteps","thumb-down"],["Out of date","outOfDate","thumb-down"],["Samples / code issue","samplesCodeIssue","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-08-07 UTC."],[[["\u003cp\u003eThis document provides reference information for the \u003ccode\u003eJobsV1Beta3.JobsV1Beta3Base\u003c/code\u003e API class within the Google Cloud Dataflow v1beta3 API, which serves as the base for server-side implementations.\u003c/p\u003e\n"],["\u003cp\u003eThe latest version of this API is \u003ccode\u003e2.0.0-beta07\u003c/code\u003e, and the documentation includes information on older versions such as \u003ccode\u003e2.0.0-beta06\u003c/code\u003e and \u003ccode\u003e1.0.0-beta03\u003c/code\u003e.\u003c/p\u003e\n"],["\u003cp\u003eThe \u003ccode\u003eJobsV1Beta3.JobsV1Beta3Base\u003c/code\u003e class includes methods for managing Dataflow jobs, such as \u003ccode\u003eAggregatedListJobs\u003c/code\u003e, \u003ccode\u003eCheckActiveJobs\u003c/code\u003e, \u003ccode\u003eCreateJob\u003c/code\u003e, \u003ccode\u003eGetJob\u003c/code\u003e, \u003ccode\u003eListJobs\u003c/code\u003e, \u003ccode\u003eSnapshotJob\u003c/code\u003e, and \u003ccode\u003eUpdateJob\u003c/code\u003e.\u003c/p\u003e\n"],["\u003cp\u003eMost job management methods, including creating, getting, listing, and updating jobs, recommend using regional endpoints for better control over job location rather than the \u003ccode\u003eus-central1\u003c/code\u003e default.\u003c/p\u003e\n"],["\u003cp\u003eThe methods listed use a \u003ccode\u003erequest\u003c/code\u003e parameter for the incoming requests, and a \u003ccode\u003econtext\u003c/code\u003e parameter for the \u003ccode\u003eServerCallContext\u003c/code\u003e, and each returns a \u003ccode\u003eTask\u003c/code\u003e wrapped response.\u003c/p\u003e\n"]]],[],null,["# Dataflow v1beta3 API - Class JobsV1Beta3.JobsV1Beta3Base (2.0.0-beta07)\n\nVersion latestkeyboard_arrow_down\n\n- [2.0.0-beta07 (latest)](/dotnet/docs/reference/Google.Cloud.Dataflow.V1Beta3/latest/Google.Cloud.Dataflow.V1Beta3.JobsV1Beta3.JobsV1Beta3Base)\n- [2.0.0-beta06](/dotnet/docs/reference/Google.Cloud.Dataflow.V1Beta3/2.0.0-beta06/Google.Cloud.Dataflow.V1Beta3.JobsV1Beta3.JobsV1Beta3Base)\n- [1.0.0-beta03](/dotnet/docs/reference/Google.Cloud.Dataflow.V1Beta3/1.0.0-beta03/Google.Cloud.Dataflow.V1Beta3.JobsV1Beta3.JobsV1Beta3Base) \n\n [BindServiceMethod(typeof(JobsV1Beta3), \"BindService\")]\n public abstract class JobsV1Beta3.JobsV1Beta3Base\n\nReference documentation and code samples for the Dataflow v1beta3 API class JobsV1Beta3.JobsV1Beta3Base.\n\nBase class for server-side implementations of JobsV1Beta3 \n\nInheritance\n-----------\n\n[object](https://learn.microsoft.com/dotnet/api/system.object) \\\u003e JobsV1Beta3.JobsV1Beta3Base \n\nInherited Members\n-----------------\n\n[object.GetHashCode()](https://learn.microsoft.com/dotnet/api/system.object.gethashcode) \n[object.GetType()](https://learn.microsoft.com/dotnet/api/system.object.gettype) \n[object.MemberwiseClone()](https://learn.microsoft.com/dotnet/api/system.object.memberwiseclone) \n[object.ToString()](https://learn.microsoft.com/dotnet/api/system.object.tostring)\n\nNamespace\n---------\n\n[Google.Cloud.Dataflow.V1Beta3](/dotnet/docs/reference/Google.Cloud.Dataflow.V1Beta3/latest/Google.Cloud.Dataflow.V1Beta3)\n\nAssembly\n--------\n\nGoogle.Cloud.Dataflow.V1Beta3.dll\n\nMethods\n-------\n\n### AggregatedListJobs(ListJobsRequest, ServerCallContext)\n\n public virtual Task\u003cListJobsResponse\u003e AggregatedListJobs(ListJobsRequest request, ServerCallContext context)\n\nList the jobs of a project across all regions.\n\n### CheckActiveJobs(CheckActiveJobsRequest, ServerCallContext)\n\n public virtual Task\u003cCheckActiveJobsResponse\u003e CheckActiveJobs(CheckActiveJobsRequest request, ServerCallContext context)\n\nCheck for existence of active jobs in the given project across all regions.\n\n### CreateJob(CreateJobRequest, ServerCallContext)\n\n public virtual Task\u003cJob\u003e CreateJob(CreateJobRequest request, ServerCallContext context)\n\nCreates a Cloud Dataflow job.\n\nTo create a job, we recommend using `projects.locations.jobs.create` with a\n[regional endpoint](https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using\n`projects.jobs.create` is not recommended, as your job will always start\nin `us-central1`.\n\n### GetJob(GetJobRequest, ServerCallContext)\n\n public virtual Task\u003cJob\u003e GetJob(GetJobRequest request, ServerCallContext context)\n\nGets the state of the specified Cloud Dataflow job.\n\nTo get the state of a job, we recommend using `projects.locations.jobs.get`\nwith a [regional endpoint](https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using\n`projects.jobs.get` is not recommended, as you can only get the state of\njobs that are running in `us-central1`.\n\n### ListJobs(ListJobsRequest, ServerCallContext)\n\n public virtual Task\u003cListJobsResponse\u003e ListJobs(ListJobsRequest request, ServerCallContext context)\n\nList the jobs of a project.\n\nTo list the jobs of a project in a region, we recommend using\n`projects.locations.jobs.list` with a [regional endpoint](https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). To\nlist the all jobs across all regions, use `projects.jobs.aggregated`. Using\n`projects.jobs.list` is not recommended, as you can only get the list of\njobs that are running in `us-central1`.\n\n### SnapshotJob(SnapshotJobRequest, ServerCallContext)\n\n public virtual Task\u003cSnapshot\u003e SnapshotJob(SnapshotJobRequest request, ServerCallContext context)\n\nSnapshot the state of a streaming job.\n\n### UpdateJob(UpdateJobRequest, ServerCallContext)\n\n public virtual Task\u003cJob\u003e UpdateJob(UpdateJobRequest request, ServerCallContext context)\n\nUpdates the state of an existing Cloud Dataflow job.\n\nTo update the state of an existing job, we recommend using\n`projects.locations.jobs.update` with a [regional endpoint](https://cloud.google.com/dataflow/docs/concepts/regional-endpoints). Using\n`projects.jobs.update` is not recommended, as you can only update the state\nof jobs that are running in `us-central1`."]]
