lint

Author: aboutphilippe

agent_telephony/twilio_livekit/agent_twilio/src/agents/agent.py

@@ -15,18 +15,37 @@
 from src.workflows.logic import LogicWorkflow, LogicWorkflowInput
 
 with import_functions():
-    from src.functions.livekit_call import LivekitCallInput, livekit_call
-    from src.functions.livekit_create_room import livekit_create_room
-    from src.functions.livekit_delete_room import livekit_delete_room
-    from src.functions.livekit_dispatch import LivekitDispatchInput, livekit_dispatch
-    from src.functions.livekit_outbound_trunk import livekit_outbound_trunk
+    from src.functions.livekit_call import (
+        LivekitCallInput,
+        livekit_call,
+    )
+    from src.functions.livekit_create_room import (
+        livekit_create_room,
+    )
+    from src.functions.livekit_delete_room import (
+        livekit_delete_room,
+    )
+    from src.functions.livekit_dispatch import (
+        LivekitDispatchInput,
+        livekit_dispatch,
+    )
+    from src.functions.livekit_outbound_trunk import (
+        livekit_outbound_trunk,
+    )
     from src.functions.livekit_send_data import (
         LivekitSendDataInput,
         SendDataResponse,
         livekit_send_data,
     )
-    from src.functions.livekit_token import LivekitTokenInput, livekit_token
-    from src.functions.llm_talk import LlmTalkInput, Message, llm_talk
+    from src.functions.livekit_token import (
+        LivekitTokenInput,
+        livekit_token,
+    )
+    from src.functions.llm_talk import (
+        LlmTalkInput,
+        Message,
+        llm_talk,
+    )
 
 
 class MessagesEvent(BaseModel):

agent_telephony/twilio_livekit/agent_twilio/src/functions/context_docs.py

@@ -3,12 +3,11 @@
 
 
 async def fetch_content_from_url(url: str) -> str:
-    async with aiohttp.ClientSession() as session:
-        async with session.get(url) as response:
-            if response.status == 200:
-                return await response.text()
-            error_message = f"Failed to fetch content: {response.status}"
-            raise NonRetryableError(error_message)
+    async with aiohttp.ClientSession() as session, session.get(url) as response:
+        if response.status == 200:
+            return await response.text()
+        error_message = f"Failed to fetch content: {response.status}"
+        raise NonRetryableError(error_message)
 
 
 @function.defn()

agent_telephony/twilio_livekit/agent_twilio/src/functions/livekit_call.py

@@ -1,7 +1,10 @@
 from dataclasses import dataclass
 
 from livekit import api
-from livekit.protocol.sip import CreateSIPParticipantRequest, SIPParticipantInfo
+from livekit.protocol.sip import (
+    CreateSIPParticipantRequest,
+    SIPParticipantInfo,
+)
 from restack_ai.function import NonRetryableError, function, log
 
 

agent_telephony/twilio_livekit/agent_twilio/src/functions/livekit_create_room.py

@@ -2,7 +2,11 @@
 
 from livekit import api
 from livekit.api import CreateRoomRequest, Room
-from restack_ai.function import NonRetryableError, function, function_info
+from restack_ai.function import (
+    NonRetryableError,
+    function,
+    function_info,
+)
 
 
 @function.defn()

agent_telephony/twilio_livekit/agent_twilio/src/functions/livekit_delete_room.py

@@ -2,7 +2,11 @@
 
 from livekit import api
 from livekit.api import DeleteRoomRequest, DeleteRoomResponse
-from restack_ai.function import NonRetryableError, function, function_info
+from restack_ai.function import (
+    NonRetryableError,
+    function,
+    function_info,
+)
 
 
 @function.defn()

agent_telephony/twilio_livekit/agent_twilio/src/functions/livekit_dispatch.py

@@ -3,7 +3,11 @@
 
 from livekit import api
 from livekit.protocol.agent_dispatch import AgentDispatch
-from restack_ai.function import NonRetryableError, function, function_info
+from restack_ai.function import (
+    NonRetryableError,
+    function,
+    function_info,
+)
 
 
 @dataclass

agent_telephony/twilio_livekit/agent_twilio/src/functions/livekit_outbound_trunk.py

@@ -6,7 +6,12 @@
     ListSIPOutboundTrunkRequest,
     SIPOutboundTrunkInfo,
 )
-from restack_ai.function import NonRetryableError, function, function_info, log
+from restack_ai.function import (
+    NonRetryableError,
+    function,
+    function_info,
+    log,
+)
 
 
 @function.defn()

agent_telephony/twilio_livekit/agent_twilio/src/functions/llm_logic.py

@@ -7,7 +7,7 @@
 
 
 class LlmLogicResponse(BaseModel):
-    """Structured AI Decision Output for Intelligent Interruptions"""
+    """Structured AI decision output used to interrupt conversations."""
 
     action: Literal["interrupt", "update_context", "end_call"]
     reason: str

agent_telephony/twilio_livekit/agent_twilio/src/functions/llm_talk.py

@@ -3,7 +3,11 @@
 
 from openai import OpenAI
 from pydantic import BaseModel, Field
-from restack_ai.function import NonRetryableError, function, stream_to_websocket
+from restack_ai.function import (
+    NonRetryableError,
+    function,
+    stream_to_websocket,
+)
 
 from src.client import api_address
 

agent_telephony/twilio_livekit/agent_twilio/src/services.py

@@ -12,7 +12,9 @@
 from src.functions.livekit_create_room import livekit_create_room
 from src.functions.livekit_delete_room import livekit_delete_room
 from src.functions.livekit_dispatch import livekit_dispatch
-from src.functions.livekit_outbound_trunk import livekit_outbound_trunk
+from src.functions.livekit_outbound_trunk import (
+    livekit_outbound_trunk,
+)
 from src.functions.livekit_send_data import livekit_send_data
 from src.functions.livekit_token import livekit_token
 from src.functions.llm_logic import llm_logic