Bump influxdb-client to 1.39.* (#11116)

Type a few task-related items

stubs/influxdb-client/METADATA.toml

@@ -1,4 +1,4 @@
-version = "1.38.*"
+version = "1.39.*"
 upstream_repository = "https://github.com/influxdata/influxdb-client-python"
 # requires a version of urllib3 with a py.typed file
 requires = ["urllib3>=2"]

stubs/influxdb-client/influxdb_client/client/tasks_api.pyi

@@ -1,11 +1,18 @@
+from collections.abc import Iterator
 from datetime import datetime
 
-from influxdb_client import LabelResponse, LogEvent, Run, Task, TaskCreateRequest, TaskUpdateRequest
+from influxdb_client import LabelResponse, LogEvent, Run, TaskCreateRequest, TaskUpdateRequest
+from influxdb_client.domain.task import Task
 
 class TasksApi:
     def __init__(self, influxdb_client) -> None: ...
     def find_task_by_id(self, task_id) -> Task: ...
-    def find_tasks(self, **kwargs): ...
+    def find_tasks(
+        self, *, name: str = ..., after: str = ..., user: str = ..., org: str = ..., org_id: str = ..., limit: int = ..., **kwargs
+    ) -> list[Task]: ...
+    def find_tasks_iter(
+        self, *, name: str = ..., after: str = ..., user: str = ..., org: str = ..., org_id: str = ..., limit: int = ..., **kwargs
+    ) -> Iterator[Task]: ...
     def create_task(self, task: Task | None = None, task_create_request: TaskCreateRequest | None = None) -> Task: ...
     def create_task_every(self, name, flux, every, organization) -> Task: ...
     def create_task_cron(self, name: str, flux: str, cron: str, org_id: str) -> Task: ...

stubs/influxdb-client/influxdb_client/domain/tasks.pyi

@@ -1,19 +1,17 @@
-from _typeshed import Incomplete
+from typing import Any, ClassVar
+
+from influxdb_client.domain.links import Links
+from influxdb_client.domain.task import Task
 
 class Tasks:
-    openapi_types: Incomplete
-    attribute_map: Incomplete
-    discriminator: Incomplete
-    def __init__(self, links: Incomplete | None = None, tasks: Incomplete | None = None) -> None: ...
-    @property
-    def links(self): ...
-    @links.setter
-    def links(self, links) -> None: ...
-    @property
-    def tasks(self): ...
-    @tasks.setter
-    def tasks(self, tasks) -> None: ...
-    def to_dict(self): ...
-    def to_str(self): ...
-    def __eq__(self, other): ...
-    def __ne__(self, other): ...
+    openapi_types: ClassVar[dict[str, str]]
+    attribute_map: ClassVar[dict[str, str]]
+
+    tasks: list[Task]
+    links: Links
+    discriminator: None
+    def __init__(self, links: Links | None = None, tasks: list[Task] | None = None) -> None: ...
+    def to_dict(self) -> dict[str, Any]: ...
+    def to_str(self) -> str: ...
+    def __eq__(self, other: object) -> bool: ...
+    def __ne__(self, other: object) -> bool: ...

stubs/influxdb-client/influxdb_client/service/tasks_service.pyi

@@ -1,5 +1,9 @@
 from _typeshed import Incomplete
+from multiprocessing.pool import ApplyResult
+from typing import overload
+from typing_extensions import Literal
 
+from influxdb_client.domain.tasks import Tasks
 from influxdb_client.service._base_service import _BaseService
 
 class TasksService(_BaseService):
@@ -19,8 +23,66 @@ class TasksService(_BaseService):
     def delete_tasks_id_runs_id(self, task_id, run_id, **kwargs): ...
     def delete_tasks_id_runs_id_with_http_info(self, task_id, run_id, **kwargs): ...
     async def delete_tasks_id_runs_id_async(self, task_id, run_id, **kwargs): ...
-    def get_tasks(self, **kwargs): ...
-    def get_tasks_with_http_info(self, **kwargs): ...
+    @overload
+    def get_tasks(
+        self,
+        *,
+        async_req: Literal[True],
+        urlopen_kw=...,
+        zap_trace_span: str = ...,
+        name: str = ...,
+        after: str = ...,
+        user: str = ...,
+        org: str = ...,
+        org_id: str = ...,
+        limit: int = ...,
+        type: str = ...,
+    ) -> ApplyResult[Tasks]: ...
+    @overload
+    def get_tasks(
+        self,
+        *,
+        async_req: Literal[False] = ...,
+        urlopen_kw=...,
+        zap_trace_span: str = ...,
+        name: str = ...,
+        after: str = ...,
+        user: str = ...,
+        org: str = ...,
+        org_id: str = ...,
+        limit: int = ...,
+        type: str = ...,
+    ) -> Tasks: ...
+    @overload
+    def get_tasks_with_http_info(
+        self,
+        *,
+        async_req: Literal[True],
+        urlopen_kw=...,
+        zap_trace_span: str = ...,
+        name: str = ...,
+        after: str = ...,
+        user: str = ...,
+        org: str = ...,
+        org_id: str = ...,
+        limit: int = ...,
+        type: str = ...,
+    ) -> ApplyResult[Tasks]: ...
+    @overload
+    def get_tasks_with_http_info(
+        self,
+        *,
+        async_req: Literal[False] = ...,
+        urlopen_kw=...,
+        zap_trace_span: str = ...,
+        name: str = ...,
+        after: str = ...,
+        user: str = ...,
+        org: str = ...,
+        org_id: str = ...,
+        limit: int = ...,
+        type: str = ...,
+    ) -> Tasks: ...
     async def get_tasks_async(self, **kwargs): ...
     def get_tasks_id(self, task_id, **kwargs): ...
     def get_tasks_id_with_http_info(self, task_id, **kwargs): ...