From 807154aaf52f6672ddff2427ef54ede0f6ab5fcf Mon Sep 17 00:00:00 2001
From: quettabit <27509167+quettabit@users.noreply.github.com>
Date: Mon, 8 Jun 2026 12:49:55 -0700
Subject: [PATCH] initial commit

---
 src/s2_sdk/_ops.py | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/src/s2_sdk/_ops.py b/src/s2_sdk/_ops.py
index e10b489..6ddfc0e 100644
--- a/src/s2_sdk/_ops.py
+++ b/src/s2_sdk/_ops.py
@@ -253,6 +253,7 @@ async def ensure_basin(
             response.json(), response.headers
         )
 
+    @fallible
     def basin(self, name: str) -> "S2Basin":
         """Get an :class:`S2Basin` for performing basin-level operations.
 
@@ -758,6 +759,7 @@ async def ensure_stream(
             response.json(), response.headers
         )
 
+    @fallible
     def stream(
         self,
         name: str,
@@ -1021,6 +1023,7 @@ async def append(self, inp: types.AppendInput) -> types.AppendAck:
         ack.ParseFromString(response.content)
         return append_ack_from_proto(ack)
 
+    @fallible
     def append_session(
         self,
         *,
@@ -1062,6 +1065,7 @@ def append_session(
             encryption_key=self._encryption_key,
         )
 
+    @fallible
     def producer(
         self,
         *,