def METHOD_NAME(pg_repo_local):
    # Create a new schema and import 'fruits' from the mounted PG table.
    OUTPUT.init()
    head = OUTPUT.head
    OUTPUT.import_tables(
        tables=["imported_fruits"], source_repository=pg_repo_local, source_tables=["fruits"]
    )
    assert OUTPUT.run_sql("SELECT * FROM imported_fruits") == pg_repo_local.run_sql(
        "SELECT * FROM fruits"
    )
    new_head = OUTPUT.head
    assert new_head != head
    assert new_head.parent_id == head.image_hash