wip

Author: quettabit

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,
         *,