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,
+        dispatch_deadline: 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 dispatch_deadline is not None:
+            task.dispatch_deadline = self.timedelta_to_duration(self.dispatch_deadline)
+
         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,
@@ -137,6 +144,7 @@ def get_task(self, queue_name: str, task_name: str, project_id: str | None = Non
         )
         return self.client.get_task(request=request)
 
+
     def delete_task(
         self,
         queue_name: str,