feat: Support and validate attemptDeadlineSeconds for GCFv2/Cloud Run scheduled functions.

Author: taeold

src/deploy/functions/backend.ts

@@ -180,13 +180,20 @@ export function isValidMemoryOption(mem: unknown): mem is MemoryOptions {
   return allMemoryOptions.includes(mem as MemoryOptions);
 }
 
-/**
- * Is a given string a valid VpcEgressSettings?
- */
 export function isValidEgressSetting(egress: unknown): egress is VpcEgressSettings {
   return egress === "PRIVATE_RANGES_ONLY" || egress === "ALL_TRAFFIC";
 }
 
+export const MIN_ATTEMPT_DEADLINE_SECONDS = 15;
+export const MAX_ATTEMPT_DEADLINE_SECONDS = 1800; // 30 mins
+
+/**
+ * Is a given number a valid attempt deadline?
+ */
+export function isValidAttemptDeadline(seconds: number): boolean {
+  return seconds >= MIN_ATTEMPT_DEADLINE_SECONDS && seconds <= MAX_ATTEMPT_DEADLINE_SECONDS;
+}
+
 /** Returns a human-readable name with MB or GB suffix for a MemoryOption (MB). */
 export function memoryOptionDisplayName(option: MemoryOptions): string {
   return {

src/deploy/functions/build.spec.ts

@@ -224,6 +224,44 @@ describe("toBackend", () => {
       expect(endpointDef.func.serviceAccount).to.equal("service-account-1@");
     }
   });
+
+  it("throws if attemptDeadlineSeconds is out of range", () => {
+    const desiredBuild: build.Build = build.of({
+      func: {
+        platform: "gcfv2",
+        region: ["us-central1"],
+        project: "project",
+        runtime: "nodejs16",
+        entryPoint: "func",
+        scheduleTrigger: {
+          schedule: "every 1 minutes",
+          attemptDeadlineSeconds: 10, // Invalid: < 15
+        },
+      },
+    });
+    expect(() => build.toBackend(desiredBuild, {})).to.throw(
+      FirebaseError,
+      /attemptDeadlineSeconds must be between 15 and 1800 seconds/,
+    );
+
+    const desiredBuild2: build.Build = build.of({
+      func: {
+        platform: "gcfv2",
+        region: ["us-central1"],
+        project: "project",
+        runtime: "nodejs16",
+        entryPoint: "func",
+        scheduleTrigger: {
+          schedule: "every 1 minutes",
+          attemptDeadlineSeconds: 1801, // Invalid: > 1800
+        },
+      },
+    });
+    expect(() => build.toBackend(desiredBuild2, {})).to.throw(
+      FirebaseError,
+      /attemptDeadlineSeconds must be between 15 and 1800 seconds/,
+    );
+  });
 });
 
 describe("envWithType", () => {

src/deploy/functions/build.ts

@@ -605,9 +605,16 @@ function discoverTrigger(endpoint: Endpoint, region: string, r: Resolver): backe
       bkSchedule.retryConfig = null;
     }
     if (typeof endpoint.scheduleTrigger.attemptDeadlineSeconds !== "undefined") {
-      bkSchedule.attemptDeadlineSeconds = r.resolveInt(
-        endpoint.scheduleTrigger.attemptDeadlineSeconds,
-      );
+      const attemptDeadlineSeconds = r.resolveInt(endpoint.scheduleTrigger.attemptDeadlineSeconds);
+      if (
+        attemptDeadlineSeconds !== null &&
+        !backend.isValidAttemptDeadline(attemptDeadlineSeconds)
+      ) {
+        throw new FirebaseError(
+          `attemptDeadlineSeconds must be between ${backend.MIN_ATTEMPT_DEADLINE_SECONDS} and ${backend.MAX_ATTEMPT_DEADLINE_SECONDS} seconds (inclusive).`,
+        );
+      }
+      bkSchedule.attemptDeadlineSeconds = attemptDeadlineSeconds;
     }
     return { scheduleTrigger: bkSchedule };
   } else if ("taskQueueTrigger" in endpoint) {

src/gcp/cloudscheduler.spec.ts

@@ -284,7 +284,7 @@ describe("cloudscheduler", () => {
       });
     });
 
-    it("should copy attemptDeadlineSeconds for v1 endpoints", async () => {
+    it("should not copy attemptDeadlineSeconds for v1 endpoints", async () => {
       expect(
         await cloudscheduler.jobFromEndpoint(
           {
@@ -301,7 +301,6 @@ describe("cloudscheduler", () => {
         name: "projects/project/locations/appEngineLocation/jobs/firebase-schedule-id-region",
         schedule: "every 1 minutes",
         timeZone: "America/Los_Angeles",
-        attemptDeadline: "300s",
         pubsubTarget: {
           topicName: "projects/project/topics/firebase-schedule-id-region",
           attributes: {
@@ -310,5 +309,33 @@ describe("cloudscheduler", () => {
         },
       });
     });
+
+    it("should copy attemptDeadlineSeconds for v2 endpoints", async () => {
+      expect(
+        await cloudscheduler.jobFromEndpoint(
+          {
+            ...V2_ENDPOINT,
+            scheduleTrigger: {
+              schedule: "every 1 minutes",
+              attemptDeadlineSeconds: 300,
+            },
+          },
+          V2_ENDPOINT.region,
+          "1234567",
+        ),
+      ).to.deep.equal({
+        name: "projects/project/locations/region/jobs/firebase-schedule-id-region",
+        schedule: "every 1 minutes",
+        timeZone: "UTC",
+        attemptDeadline: "300s",
+        httpTarget: {
+          uri: "https://my-uri.com",
+          httpMethod: "POST",
+          oidcToken: {
+            serviceAccountEmail: "1234567-compute@developer.gserviceaccount.com",
+          },
+        },
+      });
+    });
   });
 });

src/gcp/cloudscheduler.ts

@@ -262,13 +262,15 @@ export async function jobFromEndpoint(
     );
   }
   job.schedule = endpoint.scheduleTrigger.schedule;
-  proto.convertIfPresent(
-    job,
-    endpoint.scheduleTrigger,
-    "attemptDeadline",
-    "attemptDeadlineSeconds",
-    nullsafeVisitor(proto.durationFromSeconds),
-  );
+  if (endpoint.platform === "gcfv2" || endpoint.platform === "run") {
+    proto.convertIfPresent(
+      job,
+      endpoint.scheduleTrigger,
+      "attemptDeadline",
+      "attemptDeadlineSeconds",
+      nullsafeVisitor(proto.durationFromSeconds),
+    );
+  }
   if (endpoint.scheduleTrigger.retryConfig) {
     job.retryConfig = {};
     proto.copyIfPresent(