This is an automated email from the ASF dual-hosted git repository. bossenti pushed a commit to branch exp/poetry in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 0ce4e59e32fe71d73859c7eff398b4a1b1cdf55b Author: bossenti <[email protected]> AuthorDate: Mon Aug 7 19:19:54 2023 +0200 chore: reformat imports Signed-off-by: bossenti <[email protected]> --- streampipes-client-python/streampipes/client/client.py | 1 + streampipes-client-python/streampipes/endpoint/api/data_lake_measure.py | 1 + .../streampipes/functions/broker/kafka/kafka_consumer.py | 1 + .../streampipes/functions/broker/kafka/kafka_publisher.py | 1 + .../streampipes/functions/broker/nats/nats_consumer.py | 1 + .../streampipes/functions/broker/nats/nats_publisher.py | 1 + .../streampipes/model/resource/data_lake_measure.py | 1 + streampipes-client-python/streampipes/model/resource/data_series.py | 1 + streampipes-client-python/streampipes/model/resource/data_stream.py | 1 + .../streampipes/model/resource/function_definition.py | 1 + streampipes-client-python/streampipes/model/resource/query_result.py | 1 + streampipes-client-python/streampipes/model/resource/version.py | 1 + 12 files changed, 12 insertions(+) diff --git a/streampipes-client-python/streampipes/client/client.py b/streampipes-client-python/streampipes/client/client.py index 00f15b0ba..7d613d870 100644 --- a/streampipes-client-python/streampipes/client/client.py +++ b/streampipes-client-python/streampipes/client/client.py @@ -28,6 +28,7 @@ import sys from typing import Dict, Optional from requests import Session + from streampipes.client.config import StreamPipesClientConfig from streampipes.endpoint import APIEndpoint from streampipes.endpoint.api import ( diff --git a/streampipes-client-python/streampipes/endpoint/api/data_lake_measure.py b/streampipes-client-python/streampipes/endpoint/api/data_lake_measure.py index cb9497a9c..467ebbf99 100644 --- a/streampipes-client-python/streampipes/endpoint/api/data_lake_measure.py +++ b/streampipes-client-python/streampipes/endpoint/api/data_lake_measure.py @@ -23,6 +23,7 @@ from datetime import datetime from typing import Any, Dict, List, Literal, Optional, Tuple, Type from pydantic import BaseModel, Extra, Field, StrictInt, ValidationError, validator + from streampipes.endpoint.endpoint import APIEndpoint from streampipes.model.container import DataLakeMeasures from streampipes.model.container.resource_container import ResourceContainer diff --git a/streampipes-client-python/streampipes/functions/broker/kafka/kafka_consumer.py b/streampipes-client-python/streampipes/functions/broker/kafka/kafka_consumer.py index bcf5215c0..ff29b033a 100644 --- a/streampipes-client-python/streampipes/functions/broker/kafka/kafka_consumer.py +++ b/streampipes-client-python/streampipes/functions/broker/kafka/kafka_consumer.py @@ -19,6 +19,7 @@ import logging from typing import AsyncIterator from confluent_kafka import Consumer as KafkaConnection # type: ignore + from streampipes.functions.broker import Consumer from streampipes.functions.broker.kafka.kafka_message_fetcher import KafkaMessageFetcher from streampipes.model.common import random_letters diff --git a/streampipes-client-python/streampipes/functions/broker/kafka/kafka_publisher.py b/streampipes-client-python/streampipes/functions/broker/kafka/kafka_publisher.py index f55337b5a..94635f16a 100644 --- a/streampipes-client-python/streampipes/functions/broker/kafka/kafka_publisher.py +++ b/streampipes-client-python/streampipes/functions/broker/kafka/kafka_publisher.py @@ -20,6 +20,7 @@ import logging from typing import Any, Dict from confluent_kafka import Producer # type: ignore + from streampipes.functions.broker import Publisher logger = logging.getLogger(__name__) diff --git a/streampipes-client-python/streampipes/functions/broker/nats/nats_consumer.py b/streampipes-client-python/streampipes/functions/broker/nats/nats_consumer.py index ce968a5aa..895a58147 100644 --- a/streampipes-client-python/streampipes/functions/broker/nats/nats_consumer.py +++ b/streampipes-client-python/streampipes/functions/broker/nats/nats_consumer.py @@ -18,6 +18,7 @@ import logging from typing import AsyncIterator from nats import connect + from streampipes.functions.broker import Consumer logger = logging.getLogger(__name__) diff --git a/streampipes-client-python/streampipes/functions/broker/nats/nats_publisher.py b/streampipes-client-python/streampipes/functions/broker/nats/nats_publisher.py index 60543bd69..5c38c3787 100644 --- a/streampipes-client-python/streampipes/functions/broker/nats/nats_publisher.py +++ b/streampipes-client-python/streampipes/functions/broker/nats/nats_publisher.py @@ -19,6 +19,7 @@ import logging from typing import Any, Dict from nats import connect + from streampipes.functions.broker import Publisher logger = logging.getLogger(__name__) diff --git a/streampipes-client-python/streampipes/model/resource/data_lake_measure.py b/streampipes-client-python/streampipes/model/resource/data_lake_measure.py index 3d014ff92..ab8dc2cea 100644 --- a/streampipes-client-python/streampipes/model/resource/data_lake_measure.py +++ b/streampipes-client-python/streampipes/model/resource/data_lake_measure.py @@ -17,6 +17,7 @@ from typing import Optional from pydantic import StrictBool, StrictStr + from streampipes.model.common import EventSchema from streampipes.model.resource.resource import Resource diff --git a/streampipes-client-python/streampipes/model/resource/data_series.py b/streampipes-client-python/streampipes/model/resource/data_series.py index 55cefbab7..5e3ac29fe 100644 --- a/streampipes-client-python/streampipes/model/resource/data_series.py +++ b/streampipes-client-python/streampipes/model/resource/data_series.py @@ -22,6 +22,7 @@ from typing import Any, Dict, List, Optional, Union import pandas as pd from pydantic import StrictInt, StrictStr + from streampipes.model.resource.exceptions import StreamPipesUnsupportedDataSeries from streampipes.model.resource.resource import Resource diff --git a/streampipes-client-python/streampipes/model/resource/data_stream.py b/streampipes-client-python/streampipes/model/resource/data_stream.py index 6eadc0318..43ac795fd 100644 --- a/streampipes-client-python/streampipes/model/resource/data_stream.py +++ b/streampipes-client-python/streampipes/model/resource/data_stream.py @@ -17,6 +17,7 @@ from typing import List, Optional from pydantic import Field, StrictBool, StrictInt, StrictStr + from streampipes.model.common import ( ApplicationLink, EventGrounding, diff --git a/streampipes-client-python/streampipes/model/resource/function_definition.py b/streampipes-client-python/streampipes/model/resource/function_definition.py index bc09167d5..2b89d031b 100644 --- a/streampipes-client-python/streampipes/model/resource/function_definition.py +++ b/streampipes-client-python/streampipes/model/resource/function_definition.py @@ -23,6 +23,7 @@ from typing import Dict, List from uuid import uuid4 from pydantic import Field, StrictInt, StrictStr + from streampipes.model.common import BasicModel from streampipes.model.resource.data_stream import DataStream from streampipes.model.resource.resource import Resource diff --git a/streampipes-client-python/streampipes/model/resource/query_result.py b/streampipes-client-python/streampipes/model/resource/query_result.py index 03d6f3bc1..26758251e 100644 --- a/streampipes-client-python/streampipes/model/resource/query_result.py +++ b/streampipes-client-python/streampipes/model/resource/query_result.py @@ -20,6 +20,7 @@ from typing import Any, Dict, List, Literal, Union import pandas as pd from pydantic import Field, StrictInt, StrictStr + from streampipes.model.resource import DataSeries from streampipes.model.resource.exceptions import StreamPipesUnsupportedDataSeries from streampipes.model.resource.resource import Resource diff --git a/streampipes-client-python/streampipes/model/resource/version.py b/streampipes-client-python/streampipes/model/resource/version.py index c0405caec..0ec557321 100644 --- a/streampipes-client-python/streampipes/model/resource/version.py +++ b/streampipes-client-python/streampipes/model/resource/version.py @@ -22,6 +22,7 @@ __all__ = [ from typing import Dict from pydantic import StrictStr + from streampipes.model.resource.resource import Resource
