diff --git a/plugins/flytekit-snowflake/flytekitplugins/snowflake/agent.py b/plugins/flytekit-snowflake/flytekitplugins/snowflake/agent.py index c4176228ea..aaf38fd4c5 100644 --- a/plugins/flytekit-snowflake/flytekitplugins/snowflake/agent.py +++ b/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( diff --git a/plugins/flytekit-snowflake/tests/test_agent.py b/plugins/flytekit-snowflake/tests/test_agent.py index 25e2ad118c..be9936e708 100644 --- a/plugins/flytekit-snowflake/tests/test_agent.py +++ b/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)