Skip to content

Commit effd818

Browse files
fix(stream): fix get_moa_stream ValueError (#251)
1 parent 77a333f commit effd818

File tree

1 file changed

+1
-7
lines changed

1 file changed

+1
-7
lines changed

src/capymoa/stream/_stream.py

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -347,9 +347,9 @@ def next_instance(self) -> _AnyInstance:
347347
def get_schema(self) -> Schema:
348348
"""Return the schema of the stream."""
349349

350-
@abstractmethod
351350
def get_moa_stream(self) -> Optional[InstanceStream]:
352351
"""Get the MOA stream object if it exists."""
352+
return None
353353

354354
@abstractmethod
355355
def restart(self):
@@ -557,9 +557,6 @@ def next_instance(self) -> _AnyInstance:
557557
def get_schema(self):
558558
return self.schema
559559

560-
def get_moa_stream(self):
561-
raise ValueError("Not a moa_stream, a numpy read file")
562-
563560
def restart(self):
564561
self.current_instance_index = 0
565562

@@ -927,9 +924,6 @@ def next_instance(self) -> _AnyInstance:
927924
def get_schema(self):
928925
return self.schema
929926

930-
def get_moa_stream(self):
931-
raise ValueError("No moa_stream available, this is a CSV")
932-
933927
def restart(self):
934928
self.total_number_of_lines = 0
935929
self.n_lines_to_skip = 1 if self.skip_header else 0

0 commit comments

Comments
 (0)