From 328fd7ecf676012b0ef368bc5231670b9b09deab Mon Sep 17 00:00:00 2001
From: Philipp Oppermann <dev@phil-opp.com>
Date: Mon, 22 Jul 2024 12:52:07 +0200
Subject: [PATCH] Fix accidental infinite self-recursion

---
 apis/python/operator/src/lib.rs | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/apis/python/operator/src/lib.rs b/apis/python/operator/src/lib.rs
index 481b0be9..1929bc36 100644
--- a/apis/python/operator/src/lib.rs
+++ b/apis/python/operator/src/lib.rs
@@ -54,7 +54,8 @@ impl Stream for DelayedCleanup<EventStream> {
         self: std::pin::Pin<&mut Self>,
         cx: &mut std::task::Context<'_>,
     ) -> std::task::Poll<Option<Self::Item>> {
-        self.get_mut().poll_next_unpin(cx)
+        let mut inner: std::sync::MutexGuard<'_, EventStream> = self.get_mut().get_mut();
+        inner.poll_next_unpin(cx)
     }
 }