| conversation_id=conversation.id if conversation else None, | conversation_id=conversation.id if conversation else None, | ||||
| inputs=conversation.inputs | inputs=conversation.inputs | ||||
| if conversation | if conversation | ||||
| else self._prepare_user_inputs(user_inputs=inputs, variables=app_config.variables, tenant_id=app_model.id), | |||||
| else self._prepare_user_inputs( | |||||
| user_inputs=inputs, variables=app_config.variables, tenant_id=app_model.tenant_id | |||||
| ), | |||||
| query=query, | query=query, | ||||
| files=file_objs, | files=file_objs, | ||||
| parent_message_id=args.get("parent_message_id") if invoke_from != InvokeFrom.SERVICE_API else UUID_NIL, | parent_message_id=args.get("parent_message_id") if invoke_from != InvokeFrom.SERVICE_API else UUID_NIL, |
| conversation_id=conversation.id if conversation else None, | conversation_id=conversation.id if conversation else None, | ||||
| inputs=conversation.inputs | inputs=conversation.inputs | ||||
| if conversation | if conversation | ||||
| else self._prepare_user_inputs(user_inputs=inputs, variables=app_config.variables, tenant_id=app_model.id), | |||||
| else self._prepare_user_inputs( | |||||
| user_inputs=inputs, variables=app_config.variables, tenant_id=app_model.tenant_id | |||||
| ), | |||||
| query=query, | query=query, | ||||
| files=file_objs, | files=file_objs, | ||||
| parent_message_id=args.get("parent_message_id") if invoke_from != InvokeFrom.SERVICE_API else UUID_NIL, | parent_message_id=args.get("parent_message_id") if invoke_from != InvokeFrom.SERVICE_API else UUID_NIL, |
| conversation_id=conversation.id if conversation else None, | conversation_id=conversation.id if conversation else None, | ||||
| inputs=conversation.inputs | inputs=conversation.inputs | ||||
| if conversation | if conversation | ||||
| else self._prepare_user_inputs(user_inputs=inputs, variables=app_config.variables, tenant_id=app_model.id), | |||||
| else self._prepare_user_inputs( | |||||
| user_inputs=inputs, variables=app_config.variables, tenant_id=app_model.tenant_id | |||||
| ), | |||||
| query=query, | query=query, | ||||
| files=file_objs, | files=file_objs, | ||||
| parent_message_id=args.get("parent_message_id") if invoke_from != InvokeFrom.SERVICE_API else UUID_NIL, | parent_message_id=args.get("parent_message_id") if invoke_from != InvokeFrom.SERVICE_API else UUID_NIL, |
| model_conf=ModelConfigConverter.convert(app_config), | model_conf=ModelConfigConverter.convert(app_config), | ||||
| file_upload_config=file_extra_config, | file_upload_config=file_extra_config, | ||||
| inputs=self._prepare_user_inputs( | inputs=self._prepare_user_inputs( | ||||
| user_inputs=inputs, variables=app_config.variables, tenant_id=app_model.id | |||||
| user_inputs=inputs, variables=app_config.variables, tenant_id=app_model.tenant_id | |||||
| ), | ), | ||||
| query=query, | query=query, | ||||
| files=file_objs, | files=file_objs, |
| self._current_tenant = tenant | self._current_tenant = tenant | ||||
| @property | @property | ||||
| def current_tenant_id(self): | |||||
| return self._current_tenant.id | |||||
| def current_tenant_id(self) -> str | None: | |||||
| return self._current_tenant.id if self._current_tenant else None | |||||
| @current_tenant_id.setter | @current_tenant_id.setter | ||||
| def current_tenant_id(self, value: str): | def current_tenant_id(self, value: str): |