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

Change LOCAL_RUN to ENV, update examples

Browse Source
This commit is contained in:
Mark Backman
2025-07-30 20:54:18 -04:00
parent e33ca26e2d
commit f35a58abf1
3 changed files with 16 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
examples/runner-examples/01-all-transport-bot.py
View File

@@ -37,9 +37,6 @@ from pipecat.services.openai.llm import OpenAILLMService
load_dotenv(override=True)
# Check if we're running locally
IS_LOCAL_RUN = os.environ.get("LOCAL_RUN", "0") == "1"
async def run_bot(transport):
"""Main bot logic that works with any transport."""
@@ -111,18 +108,20 @@ async def bot(
if isinstance(session_args, DailyRunnerArguments):
from pipecat.transports.services.daily import DailyParams, DailyTransport
if not IS_LOCAL_RUN:
if os.environ.get("ENV") != "local":
from pipecat.audio.filters.krisp_filter import KrispFilter
krisp_filter = KrispFilter()
else:
krisp_filter = None
transport = DailyTransport(
session_args.room_url,
session_args.token,
"Pipecat Bot",
params=DailyParams(
audio_in_enabled=True,
audio_in_filter=None
if IS_LOCAL_RUN
else KrispFilter(), # Only use Krisp in production
audio_in_filter=krisp_filter,
audio_out_enabled=True,
vad_analyzer=SileroVADAnalyzer(),
),
@@ -167,6 +166,7 @@ async def bot(
call_control_id=call_data["call_control_id"],
outbound_encoding=call_data["outbound_encoding"],
inbound_encoding="PCMU", # Set manually
api_key=os.getenv("TELNYX_API_KEY", ""),
)
elif transport_type == "plivo":
@@ -175,6 +175,8 @@ async def bot(
serializer = PlivoFrameSerializer(
stream_id=call_data["stream_id"],
call_id=call_data["call_id"],
auth_id=os.getenv("PLIVO_AUTH_ID", ""),
auth_token=os.getenv("PLIVO_AUTH_TOKEN", ""),
)
else:

14
examples/runner-examples/02-two-transport-bot.py
View File

@@ -30,10 +30,6 @@ from pipecat.services.openai.llm import OpenAILLMService
load_dotenv(override=True)
# Check if we're running locally
IS_LOCAL_RUN = os.environ.get("LOCAL_RUN", "0") == "1"
async def run_bot(transport):
"""Main bot logic that works with any transport."""
logger.info(f"Starting bot")
@@ -102,18 +98,20 @@ async def bot(session_args: DailyRunnerArguments | SmallWebRTCRunnerArguments):
if isinstance(session_args, DailyRunnerArguments):
from pipecat.transports.services.daily import DailyParams, DailyTransport
if not IS_LOCAL_RUN:
if os.environ.get("ENV") != "local":
from pipecat.audio.filters.krisp_filter import KrispFilter
krisp_filter = KrispFilter()
else:
krisp_filter = None
transport = DailyTransport(
session_args.room_url,
session_args.token,
"Pipecat Bot",
params=DailyParams(
audio_in_enabled=True,
audio_in_filter=None
if IS_LOCAL_RUN
else KrispFilter(), # Only use Krisp in production
audio_in_filter=krisp_filter,
audio_out_enabled=True,
vad_analyzer=SileroVADAnalyzer(),
),

2
src/pipecat/runner/run.py
View File

@@ -94,7 +94,7 @@ except ImportError as e:
load_dotenv(override=True)
os.environ["LOCAL_RUN"] = "1"
os.environ["ENV"] = "local"
def _get_bot_module():