This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new 5cd43d5d71 fix: Fix python client Flake8 errors (#2883)
5cd43d5d71 is described below
commit 5cd43d5d7187d3ced34921af29c4f431143343f2
Author: airwish <[email protected]>
AuthorDate: Fri May 24 04:32:13 2024 +0800
fix: Fix python client Flake8 errors (#2883)
---
streampipes-client-python/Makefile | 4 ++--
streampipes-client-python/streampipes/py.typed | 2 +-
streampipes-client-python/tests/client/test_client.py | 11 +++++++++--
3 files changed, 12 insertions(+), 5 deletions(-)
diff --git a/streampipes-client-python/Makefile
b/streampipes-client-python/Makefile
index df6cb0b098..dc5510ad7b 100644
--- a/streampipes-client-python/Makefile
+++ b/streampipes-client-python/Makefile
@@ -24,7 +24,7 @@ doc:
.PHONY: lint
lint:
- poetry run flake8 streampipes --max-line-length 120
+ poetry run flake8 streampipes tests --max-line-length 120
.PHONY: livedoc
livedoc: doc
@@ -32,7 +32,7 @@ livedoc: doc
.PHONY: mypy
mypy:
- poetry run mypy streampipes --config-file pyproject.toml
+ poetry run mypy streampipes tests --config-file pyproject.toml
.PHONY: rebase
rebase:
diff --git a/streampipes-client-python/streampipes/py.typed
b/streampipes-client-python/streampipes/py.typed
index 17216e19b3..4d9d4b2ef6 100644
--- a/streampipes-client-python/streampipes/py.typed
+++ b/streampipes-client-python/streampipes/py.typed
@@ -14,4 +14,4 @@
# See the License for the specific language governing permissions and
# limitations under the License.
#
-#
\ No newline at end of file
+#
diff --git a/streampipes-client-python/tests/client/test_client.py
b/streampipes-client-python/tests/client/test_client.py
index 6e92deb880..241dab261f 100644
--- a/streampipes-client-python/tests/client/test_client.py
+++ b/streampipes-client-python/tests/client/test_client.py
@@ -119,7 +119,13 @@ class TestStreamPipesClient(TestCase):
if "streams" in kwargs["url"]:
return MockResponse(
json.dumps(
- [{"elementId": "test-stream", "name": "test",
"eventGrounding": {"transportProtocols": []}}]
+ [
+ {
+ "elementId": "test-stream",
+ "name": "test",
+ "eventGrounding": {"transportProtocols": []},
+ }
+ ]
)
)
if "versions" in kwargs["url"]:
@@ -138,7 +144,8 @@ class TestStreamPipesClient(TestCase):
mocked_logger.info.assert_has_calls(
calls=[
call(
- "\nHi there!\nYou are connected to a StreamPipes instance
running at https://localhost:443 with version SP-dev.\n"
+ "\nHi there!\nYou are connected to a StreamPipes instance
running at "
+ "https://localhost:443 with version SP-dev.\n"
"The following StreamPipes resources are available with
this client:\n"
"1x DataLakeMeasures\n1x DataStreams"
),