feature: add param attempt deadline for cloud scheduler

Author: Skyfury2651

src/deploy/functions/backend.ts

@@ -23,6 +23,7 @@ export interface ScheduleTrigger {
   schedule?: string;
   timeZone?: string | null;
   retryConfig?: ScheduleRetryConfig | null;
+  attemptDeadline?: string | null;
 }
 
 /** Something that has a ScheduleTrigger */

src/deploy/functions/build.ts

@@ -148,6 +148,7 @@ export interface ScheduleTrigger {
   schedule: string | Expression<string>;
   timeZone?: Field<string>;
   retryConfig?: ScheduleRetryConfig | null;
+  attemptDeadline?: Field<string>;
 }
 
 export type HttpsTriggered = { httpsTrigger: HttpsTrigger };
@@ -602,6 +603,9 @@ function discoverTrigger(endpoint: Endpoint, region: string, r: Resolver): backe
     if (endpoint.scheduleTrigger.timeZone !== undefined) {
       bkSchedule.timeZone = r.resolveString(endpoint.scheduleTrigger.timeZone);
     }
+    if (endpoint.scheduleTrigger.attemptDeadline !== undefined) {
+      bkSchedule.attemptDeadline = r.resolveString(endpoint.scheduleTrigger.attemptDeadline);
+    }
     if (endpoint.scheduleTrigger.retryConfig) {
       const bkRetry: backend.ScheduleRetryConfig = {};
       r.resolveInts(

src/deploy/functions/runtimes/discovery/v1alpha1.ts

@@ -222,6 +222,7 @@ function assertBuildEndpoint(ep: WireEndpoint, id: string): void {
       schedule: "Field<string>",
       timeZone: "Field<string>?",
       retryConfig: "object?",
+      attemptDeadline: "Field<string>?",
     });
     if (ep.scheduleTrigger.retryConfig) {
       assertKeyTypes(prefix + ".scheduleTrigger.retryConfig", ep.scheduleTrigger.retryConfig, {
@@ -320,6 +321,7 @@ function parseEndpointForBuild(
       // invalid values before actually modifying prod.
       schedule: ep.scheduleTrigger.schedule || "",
       timeZone: ep.scheduleTrigger.timeZone ?? null,
+      attemptDeadline: ep.scheduleTrigger.attemptDeadline ?? null,
     };
     if (ep.scheduleTrigger.retryConfig) {
       st.retryConfig = {};

src/gcp/cloudscheduler.ts

@@ -36,6 +36,7 @@ export interface HttpTarget {
   httpMethod: HttpMethod;
   headers?: Record<string, string>;
   body?: string;
+  attemptDeadline?: string;
 
   // oneof authorizationHeader
   oauthToken?: OauthToken;
@@ -249,6 +250,9 @@ export async function jobFromEndpoint(
           endpoint.serviceAccount ?? (await gce.getDefaultServiceAccount(projectNumber)),
       },
     };
+    if (endpoint.scheduleTrigger.attemptDeadline) {
+      job.httpTarget.attemptDeadline = endpoint.scheduleTrigger.attemptDeadline;
+    }
   } else {
     assertExhaustive(endpoint.platform);
   }