|
11 | 11 | import json |
12 | 12 | import uuid |
13 | 13 |
|
14 | | -from agent import DEFAULT_MODEL, TaskRunHooks, TaskAgentHooks |
| 14 | +from .agent import DEFAULT_MODEL, TaskRunHooks, TaskAgentHooks |
15 | 15 | #from agents.run import DEFAULT_MAX_TURNS # XXX: this is 10, we need more than that |
16 | 16 | from agents.exceptions import MaxTurnsExceeded, AgentsException |
17 | 17 | from agents.agent import ModelSettings |
|
22 | 22 | from openai.types.responses import ResponseTextDeltaEvent |
23 | 23 | from typing import Any |
24 | 24 |
|
25 | | -from shell_utils import shell_tool_call |
26 | | -from mcp_utils import DEFAULT_MCP_CLIENT_SESSION_TIMEOUT, ReconnectingMCPServerStdio, AsyncDebugMCPServerStdio, MCPNamespaceWrap, mcp_client_params, mcp_system_prompt, StreamableMCPThread |
27 | | -from render_utils import render_model_output, flush_async_output |
28 | | -from env_utils import TmpEnv |
29 | | -from yaml_parser import YamlParser |
30 | | -from agent import TaskAgent |
31 | | -from capi import list_tool_call_models |
32 | | -from available_tools import AvailableTools |
| 25 | +from .shell_utils import shell_tool_call |
| 26 | +from .mcp_utils import DEFAULT_MCP_CLIENT_SESSION_TIMEOUT, ReconnectingMCPServerStdio, AsyncDebugMCPServerStdio, MCPNamespaceWrap, mcp_client_params, mcp_system_prompt, StreamableMCPThread |
| 27 | +from .render_utils import render_model_output, flush_async_output |
| 28 | +from .env_utils import TmpEnv |
| 29 | +from .yaml_parser import YamlParser |
| 30 | +from .agent import TaskAgent |
| 31 | +from .capi import list_tool_call_models |
| 32 | +from .available_tools import AvailableTools |
33 | 33 |
|
34 | 34 | load_dotenv() |
35 | 35 |
|
36 | 36 | # only model output or help message should go to stdout, everything else goes to log |
37 | 37 | logging.getLogger('').setLevel(logging.NOTSET) |
| 38 | + |
| 39 | +# Create logs directory if it doesn't exist |
| 40 | +# This is needed when running the code as a package from any directory |
| 41 | +log_dir = os.path.join(os.getcwd(), 'logs') |
| 42 | +os.makedirs(log_dir, exist_ok=True) |
| 43 | + |
38 | 44 | log_file_handler = RotatingFileHandler( |
39 | | - 'logs/task_agent.log', |
| 45 | + os.path.join(log_dir, 'task_agent.log'), |
40 | 46 | maxBytes=1024*1024*10, |
41 | 47 | backupCount=10) |
42 | 48 | log_file_handler.setLevel(os.getenv('TASK_AGENT_LOGLEVEL', default='DEBUG')) |
|
0 commit comments