wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

small streamlining of example 03

Browse Source
This commit is contained in:
Kwindla Hultman Kramer
2024-03-10 19:42:19 -07:00
parent 4396b1018a
commit 959ffa9d36
1 changed files with 4 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/examples/foundational/03-still-frame.py
View File

@@ -6,48 +6,37 @@ import os
from dailyai.pipeline.frames import TextFrame from dailyai.pipeline.frames import TextFrame
from dailyai.services.daily_transport_service import DailyTransportService from dailyai.services.daily_transport_service import DailyTransportService
from dailyai.services.fal_ai_services import FalImageGenService from dailyai.services.fal_ai_services import FalImageGenService
from dailyai.services.open_ai_services import OpenAIImageGenService
from dailyai.services.azure_ai_services import AzureImageGenServiceREST
from examples.support.runner import configure from examples.support.runner import configure
logging.basicConfig(format=f"%(levelno)s %(asctime)s %(message)s") logging.basicConfig(format=f"%(levelno)s %(asctime)s %(message)s")
logger = logging.getLogger("dailyai") logger = logging.getLogger("dailyai")
logger.setLevel(logging.DEBUG) logger.setLevel(logging.DEBUG)
local_joined = False
participant_joined = False
async def main(room_url): async def main(room_url):
async with aiohttp.ClientSession() as session: async with aiohttp.ClientSession() as session:
meeting_duration_minutes = 1
transport = DailyTransportService( transport = DailyTransportService(
room_url, room_url,
None, None,
"Show a still frame image", "Show a still frame image",
duration_minutes=meeting_duration_minutes,
mic_enabled=False,
camera_enabled=True, camera_enabled=True,
camera_width=1024, camera_width=1024,
camera_height=1024, camera_height=1024,
) )
imagegen = FalImageGenService( imagegen = FalImageGenService(
image_size="1024x1024", image_size="square_hd",
aiohttp_session=session, aiohttp_session=session,
key_id=os.getenv("FAL_KEY_ID"), key_id=os.getenv("FAL_KEY_ID"),
key_secret=os.getenv("FAL_KEY_SECRET"), key_secret=os.getenv("FAL_KEY_SECRET"),
) )
image_task = asyncio.create_task(
imagegen.run_to_queue(
transport.send_queue, [TextFrame("a cat in the style of picasso")]
)
)
@transport.event_handler("on_first_other_participant_joined") @transport.event_handler("on_first_other_participant_joined")
async def on_first_other_participant_joined(transport): async def on_first_other_participant_joined(transport):
await image_task await imagegen.run_to_queue(
transport.send_queue, [TextFrame("a cat in the style of picasso")]
)
await transport.run() await transport.run()