Skip to content

Commit 036c270

Browse files
shawn-yang-googlecopybara-github
authored andcommitted
feat: add logging for agent engine creation
PiperOrigin-RevId: 776644637
1 parent 57010a3 commit 036c270

File tree

1 file changed

+13
-4
lines changed

1 file changed

+13
-4
lines changed

vertexai/_genai/agent_engines.py

Lines changed: 13 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -920,6 +920,7 @@ def _RetrieveMemoriesResponse_from_vertex(
920920

921921

922922
class AgentEngines(_api_module.BaseModule):
923+
923924
def _create(
924925
self, *, config: Optional[types.CreateAgentEngineConfigOrDict] = None
925926
) -> types.AgentEngineOperation:
@@ -1988,12 +1989,20 @@ def create(
19881989
env_vars=config.env_vars,
19891990
)
19901991
operation = self._create(config=api_config)
1992+
logger.info(
1993+
"View progress and logs at"
1994+
f" https://console.cloud.google.com/logs/query?project={self._api_client.project}."
1995+
)
19911996
operation = self._await_operation(operation_name=operation.name)
19921997
agent = types.AgentEngine(
19931998
api_client=self,
19941999
api_async_client=AsyncAgentEngines(api_client_=self._api_client),
19952000
api_resource=operation.response,
19962001
)
2002+
logger.info("Agent Engine created. To use it in another session:")
2003+
logger.info(
2004+
"agent_engine =" f" client.agent_engines.get('{agent.api_resource.name}')"
2005+
)
19972006
if agent_engine is not None:
19982007
# If the user did not provide an agent_engine (e.g. lightweight
19992008
# provisioning), it will not have any API methods registered.
@@ -2082,10 +2091,9 @@ def _create_config(
20822091
)
20832092
agent_engine_spec = {"package_spec": package_spec}
20842093
if env_vars is not None:
2085-
(
2086-
deployment_spec,
2087-
deployment_update_masks,
2088-
) = self._generate_deployment_spec_or_raise(env_vars=env_vars)
2094+
deployment_spec, deployment_update_masks = (
2095+
self._generate_deployment_spec_or_raise(env_vars=env_vars)
2096+
)
20892097
update_masks.extend(deployment_update_masks)
20902098
agent_engine_spec["deployment_spec"] = deployment_spec
20912099
class_methods = _agent_engines._generate_class_methods_spec_or_raise(
@@ -2515,6 +2523,7 @@ def retrieve_memories(
25152523

25162524

25172525
class AsyncAgentEngines(_api_module.BaseModule):
2526+
25182527
async def _create(
25192528
self, *, config: Optional[types.CreateAgentEngineConfigOrDict] = None
25202529
) -> types.AgentEngineOperation:

0 commit comments

Comments
 (0)