chore: Introduces overwrite field to jobs (#754)

javier-aliaga · web-flow · commit 1b45150dd40b · 2025-08-07T14:06:28.000-07:00
Signed-off-by: Javier Aliaga &lt;javier@diagrid.io&gt;
diff --git a/client/jobs.go b/client/jobs.go
@@ -68,6 +68,7 @@ type Job struct {
 	TTL           *string
 	Data          *anypb.Any
 	FailurePolicy FailurePolicy
+	Overwrite     bool
 }
 
 type JobOption func(*Job)
@@ -176,7 +177,8 @@ func (c *GRPCClient) ScheduleJobAlpha1(ctx context.Context, job *Job) error {
 		jobRequest.FailurePolicy = job.FailurePolicy.GetPBFailurePolicy()
 	}
 	_, err := c.protoClient.ScheduleJobAlpha1(ctx, &runtimepb.ScheduleJobRequest{
-		Job: jobRequest,
+		Job:       jobRequest,
+		Overwrite: job.Overwrite,
 	})
 	return err
 }

Original file line number	Diff line number	Diff line change
`@@ -68,6 +68,7 @@ type Job struct {`
`68`	`68`	`TTL *string`
`69`	`69`	`Data *anypb.Any`
`70`	`70`	`FailurePolicy FailurePolicy`
	`71`	`+ Overwrite bool`
`71`	`72`	`}`
`72`	`73`
`73`	`74`	`type JobOption func(*Job)`
`@@ -176,7 +177,8 @@ func (c GRPCClient) ScheduleJobAlpha1(ctx context.Context, job Job) error {`
`176`	`177`	`jobRequest.FailurePolicy = job.FailurePolicy.GetPBFailurePolicy()`
`177`	`178`	`}`
`178`	`179`	`_, err := c.protoClient.ScheduleJobAlpha1(ctx, &runtimepb.ScheduleJobRequest{`
`179`		`- Job: jobRequest,`
	`180`	`+ Job: jobRequest,`
	`181`	`+ Overwrite: job.Overwrite,`
`180`	`182`	`})`
`181`	`183`	`return err`
`182`	`184`	`}`