diff --git a/python_modules/dagster/dagster/_core/ext/client.py b/python_modules/dagster/dagster/_core/ext/client.py index 5d96312eb9eb7..6884b86385d94 100644 --- a/python_modules/dagster/dagster/_core/ext/client.py +++ b/python_modules/dagster/dagster/_core/ext/client.py @@ -34,3 +34,9 @@ class ExtMessageReader(ABC): @abstractmethod @contextmanager def read_messages(self, handler: "ExtMessageHandler") -> Iterator[ExtParams]: ... + + +class ExtLogReader(ABC): + @abstractmethod + @contextmanager + def read_logs(self) -> Iterator[ExtParams]: ...