Update agent uri format (#1861)

Signed-off-by: HH <hhcs9527@gmail.com>

plugins/flytekit-snowflake/flytekitplugins/snowflake/agent.py

@@ -81,7 +81,7 @@ async def async_create(
                 name: TypeEngine.guess_python_type(lt.type) for name, lt in task_template.interface.inputs.items()
             }
             native_inputs = TypeEngine.literal_map_to_kwargs(ctx, inputs, python_interface_inputs)
-            logger.info(f"Create Snowflake params with inputs: {native_inputs}")
+            logger.info(f"Create Snowflake agent params with inputs: {native_inputs}")
             params = native_inputs
 
         config = task_template.config
@@ -125,7 +125,7 @@ async def async_get(self, context: grpc.ServicerContext, resource_meta: bytes) -
 
         if cur_state == SUCCEEDED:
             ctx = FlyteContextManager.current_context()
-            output_metadata = f"snowflake://{metadata.user}:{metadata.account}/{metadata.database}/{metadata.schema}/{metadata.warehouse}/{metadata.table}"
+            output_metadata = f"snowflake://{metadata.user}:{metadata.account}/{metadata.warehouse}/{metadata.database}/{metadata.schema}/{metadata.table}"
             res = literals.LiteralMap(
                 {
                     "results": TypeEngine.to_literal(

plugins/flytekit-snowflake/tests/test_agent.py

@@ -100,7 +100,7 @@ async def test_snowflake_agent(mock_conn, mock_get_private_key):
     assert res.resource.state == SUCCEEDED
     assert (
         res.resource.outputs.literals["results"].scalar.structured_dataset.uri
-        == "snowflake://dummy_user:dummy_account/dummy_database/dummy_schema/dummy_warehouse/dummy_table"
+        == "snowflake://dummy_user:dummy_account/dummy_warehouse/dummy_database/dummy_schema/dummy_table"
     )
 
     delete_response = await agent.async_delete(ctx, metadata_bytes)