Skip to content

Commit

Permalink
fix settings load bug
Browse files Browse the repository at this point in the history
  • Loading branch information
victordibia committed Feb 23, 2025
1 parent 1be2a02 commit c50d0aa
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -95,7 +95,7 @@ async def start_stream(self, run_id: UUID, task: str, team_config: dict) -> None
run = await self._get_run(run_id)
# get user Settings
user_settings = await self._get_settings(run.user_id)
user_settings = SettingsConfig(**user_settings.config)
env_vars = SettingsConfig(**user_settings.config).environment if user_settings else None
if run:
run.task = MessageConfig(content=task, source="user").model_dump()
run.status = RunStatus.ACTIVE
Expand All @@ -108,7 +108,7 @@ async def start_stream(self, run_id: UUID, task: str, team_config: dict) -> None
team_config=team_config,
input_func=input_func,
cancellation_token=cancellation_token,
env_vars=user_settings.environment,
env_vars=env_vars,
):
if cancellation_token.is_cancelled() or run_id in self._closed_connections:
logger.info(f"Stream cancelled or connection closed for run {run_id}")
Expand Down

0 comments on commit c50d0aa

Please sign in to comment.