diff --git a/apps/docs/spec/supabase_py_v2.yml b/apps/docs/spec/supabase_py_v2.yml
index a66caf6e064..189d73539df 100644
--- a/apps/docs/spec/supabase_py_v2.yml
+++ b/apps/docs/spec/supabase_py_v2.yml
@@ -6425,72 +6425,81 @@ functions:
         isSpotlight: true
         code: |
           ```python
-          channel = supabase.channel("room1")
+          channel = await supabase.channel("room1")
 
           def on_subscribe(status, err):
             if status == RealtimeSubscribeStates.SUBSCRIBED:
-              channel.send_broadcast('cursor-pos', { "x": random.random(), "y": random.random() })
+              asyncio.create_task(
+                channel.send_broadcast('cursor-pos', { "x": random.random(), "y": random.random() })
+              )
 
           def handle_broadcast(payload):
             print("Cursor position received!", payload)
 
-          channel.on_broadcast(event="cursor-pos", callback=handle_broadcast).subscribe(on_subscribe)
+          await channel.on_broadcast(event="cursor-pos", callback=handle_broadcast).subscribe(on_subscribe)
           ```
       - id: listen-to-presence-sync
         name: Listen to presence sync
         isSpotlight: true
         code: |
           ```python
-          channel = supabase.channel('room1')
+          channel = await supabase.channel('room1')
 
           def on_subscribe(status, err):
             if status == RealtimeSubscribeStates.SUBSCRIBED:
-              channel.track({ "online_at": datetime.datetime.now().isoformat() })
+              asyncio.create_task(
+                channel.track({ "online_at": datetime.datetime.now().isoformat() })
+              )
 
           def handle_presence_sync():
             print('Synced presence state: ', channel.presence.state)
 
-          channel.on_presence_sync(callback=handle_presence_sync).subscribe(on_subscribe)
+          await channel.on_presence_sync(callback=handle_presence_sync).subscribe(on_subscribe)
           ```
       - id: listen-to-presence-join
         name: Listen to presence join
         isSpotlight: true
         code: |
           ```python
-          channel = supabase.channel('room1')
+          channel = await supabase.channel('room1')
 
           def handle_presence_join(key, current_presence, new_presence):
             print('Newly joined presences: ', new_presence)
 
           def on_subscribe(status, err):
             if status == RealtimeSubscribeStates.SUBSCRIBED:
-              channel.track({ "online_at": datetime.datetime.now().isoformat() })
+              asyncio.create_task(
+                channel.track({ "online_at": datetime.datetime.now().isoformat() })
+              )
 
-          channel.on_presence_join(callback=handle_presence_join).subscribe(on_subscribe)
+          await channel.on_presence_join(callback=handle_presence_join).subscribe(on_subscribe)
           ```
       - id: listen-to-presence-leave
         name: Listen to presence leave
         isSpotlight: true
         code: |
           ```python
-          channel = supabase.channel('room1')
+          channel = await supabase.channel('room1')
 
           def handle_presence_leave(key, current_presence, left_presence):
             print('Newly left presences: ', left_presence)
 
           def on_subscribe(status, err):
             if status == RealtimeSubscribeStates.SUBSCRIBED:
-              channel.track({ "online_at": datetime.datetime.now().isoformat() })
-              channel.untrack()
+              async def subscribed():
+                await channel.track({ "online_at": datetime.datetime.now().isoformat() })
+                await channel.untrack()
+              
+              asyncio.create_task(subscribed())
 
-          channel.on_presence_leave(callback=handle_presence_leave).subscribe(on_subscribe)
+          await channel.on_presence_leave(callback=handle_presence_leave).subscribe(on_subscribe)
           ```
       - id: listen-to-all-database-changes
         name: Listen to all database changes
         isSpotlight: true
         code: |
           ```python
-          supabase
+          await supabase
             .channel('room1')
             .on_postgres_changes("*", schema="*", callback=handle_record_updated)
             .subscribe()
@@ -6499,7 +6508,7 @@ functions:
         name: Listen to a specific table
         code: |
           ```python
-          supabase
+          await supabase
             .channel('room1')
             .on_postgres_changes("*", schema="public", table="countries", callback=handle_record_updated)
             .subscribe()
@@ -6508,7 +6517,7 @@ functions:
         name: Listen to inserts
         code: |
           ```python
-          supabase
+          await supabase
             .channel('room1')
             .on_postgres_changes("INSERT", schema="public", table="countries", callback=handle_record_inserted)
             .subscribe()
@@ -6524,7 +6533,7 @@ functions:
           ```
         code: |
           ```python
-          supabase
+          await supabase
             .channel('room1')
             .on_postgres_changes("UPDATE", schema="public", table="countries", callback=handle_record_updated)
             .subscribe()
@@ -6540,7 +6549,7 @@ functions:
           ```
         code: |
           ```python
-          supabase
+          await supabase
             .channel('room1')
             .on_postgres_changes("DELETE", schema="public", table="countries", callback=handle_record_deleted)
             .subscribe()
@@ -6550,7 +6559,7 @@ functions:
         description: You can chain listeners if you want to listen to multiple events for each table.
         code: |
           ```python
-          supabase
+          await supabase
             .channel('room1')
             .on_postgres_changes("INSERT", schema="public", table="countries", callback=handle_record_inserted)
             .on_postgres_changes("DELETE", schema="public", table="countries", callback=handle_record_deleted)
@@ -6563,7 +6572,7 @@ functions:
           - ``eq`` filter works with all database types as under the hood, it's casting both the filter value and the database value to the correct type and then comparing them.
         code: |
           ```python
-          supabase
+          await supabase
             .channel('room1')
             .on_postgres_changes("UPDATE", schema="public", table="countries", filter="id=eq.200", callback=handle_record_updated)
             .subscribe()
@@ -6578,13 +6587,15 @@ functions:
         isSpotlight: true
         code: |
           ```python
-          channel = supabase.channel('room1')
+          channel = await supabase.channel('room1')
 
           def on_subscribe(status, err):
             if status == RealtimeSubscribeStates.SUBSCRIBED:
-              channel.send_broadcast('cursor-pos', { "x": random.random(), "y": random.random() })
+              asyncio.create_task(
+                channel.send_broadcast('cursor-pos', { "x": random.random(), "y": random.random() })
+              )
 
-          channel.subscribe(on_subscribe)
+          await channel.subscribe(on_subscribe)
           ```
         response: |
           ```
@@ -6598,7 +6609,7 @@ functions:
         isSpotlight: true
         code: |
           ```python
-          channels = supabase.get_channels()
+          channels = await supabase.get_channels()
           ```
 
   - id: remove-channel
@@ -6611,7 +6622,7 @@ functions:
         isSpotlight: true
         code: |
           ```python
-          supabase.remove_channel(myChannel)
+          await supabase.remove_channel(myChannel)
           ```
 
   - id: remove-all-channels
@@ -6624,7 +6635,7 @@ functions:
         isSpotlight: true
         code: |
           ```python
-          supabase.remove_all_channels()
+          await supabase.remove_all_channels()
           ```
 
   - id: list-buckets