diff --git a/packages/opal-client/opal_client/engine/runner.py b/packages/opal-client/opal_client/engine/runner.py
index 0be82a3f..9cca62c2 100644
--- a/packages/opal-client/opal_client/engine/runner.py
+++ b/packages/opal-client/opal_client/engine/runner.py
@@ -231,9 +231,6 @@ def _init_events(self):
         if self._should_stop is None:
             self._should_stop = asyncio.Event()
 
-    async def pipe_logs(self, stream, logs_format: EngineLogFormat):
-        raise NotImplementedError()
-
 
 class OpaRunner(PolicyEngineRunner):
     PANIC_DETECTION_SUBSTRINGS = [b"go/src/runtime/panic.go"]