Skip to content

Commit

Permalink
Solve linting
Browse files Browse the repository at this point in the history
  • Loading branch information
irux committed Sep 18, 2023
1 parent b956ebc commit df16d00
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 12 deletions.
2 changes: 0 additions & 2 deletions kpops/components/base_components/pipeline_component.py
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
from __future__ import annotations

from abc import ABC
from itertools import chain
from typing import Iterator

from pydantic import Extra, Field
Expand Down Expand Up @@ -145,7 +144,6 @@ def outputs(self) -> Iterator[str]:
yield self.get_output_topic()
yield from self.get_extra_output_topics().values()


def __get_all_output_topics(self) -> list[str]:
all_output_topics: list[str] = []
output_topic = self.get_output_topic()
Expand Down
16 changes: 6 additions & 10 deletions tests/components/test_streams_app.py
Original file line number Diff line number Diff line change
Expand Up @@ -472,14 +472,12 @@ async def test_get_input_output_topics(
},
}
},
"to": {"topics": {
"example-output": {
"type": "output"
},
"extra-topic":{
"role": "fake-role"
"to": {
"topics": {
"example-output": {"type": "output"},
"extra-topic": {"role": "fake-role"},
}
}},
},
},
)

Expand All @@ -489,6 +487,4 @@ async def test_get_input_output_topics(
"role2": ["topic-extra2", "topic-extra3"],
}
assert streams_app.get_output_topic() == "example-output"
assert streams_app.get_extra_output_topics() == {
"fake-role": "extra-topic"
}
assert streams_app.get_extra_output_topics() == {"fake-role": "extra-topic"}

0 comments on commit df16d00

Please sign in to comment.