Skip to content

Commit

Permalink
Fix ruff formatting on examples/room_example.py
Browse files Browse the repository at this point in the history
  • Loading branch information
davidzhao committed Nov 28, 2024
1 parent 99f79c3 commit f763895
Showing 1 changed file with 10 additions and 6 deletions.
16 changes: 10 additions & 6 deletions examples/room_example.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,15 +7,16 @@
TOKEN = os.environ.get("LIVEKIT_TOKEN")
URL = os.environ.get("LIVEKIT_URL")


async def main():
logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__)
room = rtc.Room()

@room.on("participant_connected")
def on_participant_connected(participant: rtc.RemoteParticipant):
logging.info(
"participant connected: %s %s", participant.sid, participant.identity)
"participant connected: %s %s", participant.sid, participant.identity
)

async def receive_frames(stream: rtc.VideoStream):
async for frame in stream:
Expand All @@ -24,7 +25,11 @@ async def receive_frames(stream: rtc.VideoStream):

# track_subscribed is emitted whenever the local participant is subscribed to a new track
@room.on("track_subscribed")
def on_track_subscribed(track: rtc.Track, publication: rtc.RemoteTrackPublication, participant: rtc.RemoteParticipant):
def on_track_subscribed(
track: rtc.Track,
publication: rtc.RemoteTrackPublication,
participant: rtc.RemoteParticipant,
):
logging.info("track subscribed: %s", publication.sid)
if track.kind == rtc.TrackKind.KIND_VIDEO:
video_stream = rtc.VideoStream(track)
Expand All @@ -43,7 +48,8 @@ def on_track_subscribed(track: rtc.Track, publication: rtc.RemoteTrackPublicatio
print(f"participant identity: {participant.identity}")
print(f"participant name: {participant.name}")
print(f"participant kind: {participant.kind}")
print(f"participant track publications: {participant.track_publications}")
print(f"participant track publications: {
participant.track_publications}")
for tid, publication in participant.track_publications.items():
print(f"\ttrack id: {tid}")
print(f"\t\ttrack publication: {publication}")
Expand All @@ -52,7 +58,6 @@ def on_track_subscribed(track: rtc.Track, publication: rtc.RemoteTrackPublicatio
print(f"\t\ttrack source: {publication.source}")

print(f"participant metadata: {participant.metadata}")



if __name__ == "__main__":
Expand All @@ -62,4 +67,3 @@ def on_track_subscribed(track: rtc.Track, publication: rtc.RemoteTrackPublicatio
exit(1)

asyncio.run(main())

0 comments on commit f763895

Please sign in to comment.