feat: add dispatch_deadline parameter to tasks_v2.Task

gcp_pilot/tasks.py

@@ -46,6 +46,7 @@ def push(
         use_oidc_auth: bool = True,
         content_type: str | None = None,
         headers: dict[str, str] | None = None,
+        task_timeout: timedelta | None = None,
     ) -> tasks_v2.Task:
         queue_path = self.client.queue_path(
             project=project_id or self.project_id,
@@ -81,6 +82,9 @@ def push(
             ),
         )
 
+        if task_timeout is not None:
+            task.dispatch_deadline = self.timedelta_to_duration(task_timeout)
+
         if delay_in_seconds:
             target_date = datetime.now(tz=UTC) + timedelta(seconds=delay_in_seconds)
             timestamp = timestamp_pb2.Timestamp()
@@ -116,6 +120,9 @@ def create_queue(
             queue=queue,
         )
 
+    def timedelta_to_duration(delta: timedelta) -> str:
+        return f"{int(delta.total_seconds())}s"
+
     def get_queue(
         self,
         queue_name: str,

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "gcp-pilot"
-version = "1.31.0"
+version = "1.32.0"
 description = "Google Cloud Platform Friendly Pilot"
 authors = [
     {name = "Joao Daher", email = "[email protected]"},