Skip to content

Commit

Permalink
Fix e2e tests
Browse files Browse the repository at this point in the history
  • Loading branch information
Antonio Andelic committed Nov 30, 2021
1 parent 12bf648 commit 758a09b
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
4 changes: 2 additions & 2 deletions tests/e2e/streams/kafka_streams_tests.py
Expand Up @@ -216,8 +216,8 @@ def test_show_streams(kafka_producer, kafka_topics, connection):
"default_values",
("default_values",
"kafka",
None,
None,
100,
1000,
"kafka_transform.simple",
None,
False),
Expand Down
4 changes: 2 additions & 2 deletions tests/e2e/streams/pulsar_streams_tests.py
Expand Up @@ -266,8 +266,8 @@ def test_show_streams(pulsar_client, pulsar_topics, connection):
"default_values",
("default_values",
"pulsar",
None,
None,
100,
1000,
"pulsar_transform.simple",
None,
False),
Expand Down
2 changes: 1 addition & 1 deletion tests/e2e/streams/streams_owner_tests.py
Expand Up @@ -77,7 +77,7 @@ def test_owner_is_shown(kafka_topics, connection):
f"TOPICS {kafka_topics[0]} "
f"TRANSFORM kafka_transform.simple")

common.check_stream_info(userless_cursor, "test", ("test", "kafka", None, None,
common.check_stream_info(userless_cursor, "test", ("test", "kafka", 100, 1000,
"kafka_transform.simple", stream_user, False))


Expand Down

0 comments on commit 758a09b

Please sign in to comment.