diff --git a/python_modules/dagster/dagster/_core/ext/client.py b/python_modules/dagster/dagster/_core/ext/client.py index 47270207bb62e..9eb7b35596791 100644 --- a/python_modules/dagster/dagster/_core/ext/client.py +++ b/python_modules/dagster/dagster/_core/ext/client.py @@ -36,3 +36,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]: ...