Skip to content

Commit 3581846

Browse files
srittausrittau
authored
Bump influxdb-client to 1.41.* (#11608)
1 parent bd33ada commit 3581846

File tree

6 files changed

+38
-23
lines changed

6 files changed

+38
-23
lines changed

‎stubs/influxdb-client/METADATA.toml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
version = "1.40.*"
1+
version = "1.41.*"
22
upstream_repository = "https://github.com/influxdata/influxdb-client-python"
33
# requires a version of urllib3 with a py.typed file
44
requires = ["urllib3>=2"]

‎stubs/influxdb-client/influxdb_client/client/flux_csv_parser.pyi

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,7 @@ class FluxCsvParser:
4545
data_frame_index: list[str] | None = None,
4646
query_options: Incomplete | None = None,
4747
response_metadata_mode: FluxResponseMetadataMode = ...,
48+
use_extension_dtypes: bool = False,
4849
) -> None: ...
4950
def __enter__(self) -> Self: ...
5051
def __exit__(

‎stubs/influxdb-client/influxdb_client/client/query_api.pyi

Lines changed: 12 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,11 @@
1-
from _typeshed import Incomplete
1+
from _typeshed import Incomplete, SupportsItems
22
from collections.abc import Callable, Generator
33
from typing import Any
44

55
from influxdb_client import Dialect
66
from influxdb_client.client._base import _BaseQueryApi
77
from influxdb_client.client.flux_table import CSVIterator, FluxRecord, TableList
8+
from influxdb_client.domain.organization import Organization
89

910
class QueryOptions:
1011
profilers: Incomplete
@@ -20,29 +21,31 @@ class QueryApi(_BaseQueryApi):
2021
query: str,
2122
org: Incomplete | None = None,
2223
dialect: Dialect = ...,
23-
params: dict[Incomplete, Incomplete] | None = None,
24+
params: SupportsItems[str, Incomplete] | None = None,
2425
) -> CSVIterator: ...
2526
def query_raw(
26-
self, query: str, org: Incomplete | None = None, dialect=..., params: dict[Incomplete, Incomplete] | None = None
27+
self, query: str, org: Incomplete | None = None, dialect=..., params: SupportsItems[str, Incomplete] | None = None
2728
): ...
2829
def query(
29-
self, query: str, org: Incomplete | None = None, params: dict[Incomplete, Incomplete] | None = None
30+
self, query: str, org: Incomplete | None = None, params: SupportsItems[str, Incomplete] | None = None
3031
) -> TableList: ...
3132
def query_stream(
32-
self, query: str, org: Incomplete | None = None, params: dict[Incomplete, Incomplete] | None = None
33+
self, query: str, org: Incomplete | None = None, params: SupportsItems[str, Incomplete] | None = None
3334
) -> Generator[FluxRecord, Any, None]: ...
3435
def query_data_frame(
3536
self,
3637
query: str,
37-
org: Incomplete | None = None,
38+
org: Organization | str | None = None,
3839
data_frame_index: list[str] | None = None,
39-
params: dict[Incomplete, Incomplete] | None = None,
40+
params: SupportsItems[str, Incomplete] | None = None,
41+
use_extension_dtypes: bool = False,
4042
): ...
4143
def query_data_frame_stream(
4244
self,
4345
query: str,
44-
org: Incomplete | None = None,
46+
org: Organization | str | None = None,
4547
data_frame_index: list[str] | None = None,
46-
params: dict[Incomplete, Incomplete] | None = None,
48+
params: SupportsItems[str, Incomplete] | None = None,
49+
use_extension_dtypes: bool = False,
4750
): ...
4851
def __del__(self) -> None: ...

‎stubs/influxdb-client/influxdb_client/client/query_api_async.pyi

Lines changed: 17 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,31 +1,39 @@
1-
from _typeshed import Incomplete
1+
from _typeshed import Incomplete, SupportsItems
22
from collections.abc import AsyncGenerator
33

44
from influxdb_client.client._base import _BaseQueryApi
55
from influxdb_client.client.flux_table import FluxRecord, TableList
6+
from influxdb_client.domain.dialect import Dialect
7+
from influxdb_client.domain.organization import Organization
68

79
class QueryApiAsync(_BaseQueryApi):
810
def __init__(self, influxdb_client, query_options=...) -> None: ...
911
async def query(
10-
self, query: str, org: Incomplete | None = None, params: dict[Incomplete, Incomplete] | None = None
12+
self, query: str, org: Incomplete | None = None, params: SupportsItems[str, Incomplete] | None = None
1113
) -> TableList: ...
1214
async def query_stream(
13-
self, query: str, org: Incomplete | None = None, params: dict[Incomplete, Incomplete] | None = None
15+
self, query: str, org: Incomplete | None = None, params: SupportsItems[str, Incomplete] | None = None
1416
) -> AsyncGenerator[FluxRecord, None]: ...
1517
async def query_data_frame(
1618
self,
1719
query: str,
18-
org: Incomplete | None = None,
20+
org: str | Organization | None = None,
1921
data_frame_index: list[str] | None = None,
20-
params: dict[Incomplete, Incomplete] | None = None,
22+
params: SupportsItems[str, Incomplete] | None = None,
23+
use_extension_dtypes: bool = False,
2124
): ...
2225
async def query_data_frame_stream(
2326
self,
2427
query: str,
25-
org: Incomplete | None = None,
28+
org: str | Organization | None = None,
2629
data_frame_index: list[str] | None = None,
27-
params: dict[Incomplete, Incomplete] | None = None,
30+
params: SupportsItems[str, Incomplete] | None = None,
31+
use_extension_dtypes: bool = False,
2832
): ...
2933
async def query_raw(
30-
self, query: str, org: Incomplete | None = None, dialect=..., params: dict[Incomplete, Incomplete] | None = None
31-
): ...
34+
self,
35+
query: str,
36+
org: str | Organization | None = None,
37+
dialect: Dialect = ...,
38+
params: SupportsItems[str, Incomplete] | None = None,
39+
) -> str: ...

‎stubs/influxdb-client/influxdb_client/client/util/helpers.pyi

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1,4 @@
1-
def get_org_query_param(org, client, required_id: bool = False): ...
1+
from influxdb_client.client.influxdb_client import InfluxDBClient
2+
from influxdb_client.domain.organization import Organization
3+
4+
def get_org_query_param(org: Organization | str | None, client: InfluxDBClient, required_id: bool = False) -> str: ...

‎stubs/influxdb-client/influxdb_client/domain/organization.pyi

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ class Organization:
77
def __init__(
88
self,
99
links: Incomplete | None = None,
10-
id: Incomplete | None = None,
10+
id: str | None = None,
1111
name: Incomplete | None = None,
1212
default_storage_type: str | None = None,
1313
description: Incomplete | None = None,
@@ -20,9 +20,9 @@ class Organization:
2020
@links.setter
2121
def links(self, links) -> None: ...
2222
@property
23-
def id(self): ...
23+
def id(self) -> str: ...
2424
@id.setter
25-
def id(self, id) -> None: ...
25+
def id(self, id: str) -> None: ...
2626
@property
2727
def name(self): ...
2828
@name.setter

0 commit comments

Comments
 (0)