Fabric User Data Function throws error while attempting call from data pipeline

For my post, adding a code block for this issue for more analysis..

User Data function

import datetime

import fabric.functions as fn

import logging

udf = fn.UserDataFunctions()

#@udf.function()

# Replace the alias "<My Lakehouse alias>" with your connection alias.

@udf.connection(argName="myLakehouse", alias="lhreporting")

@udf.function()

def query_data_from_tables(myLakehouse: fn.FabricLakehouseClient) -> list:

    # Connect to the Lakehouse SQL Endpoint

    connection = myLakehouse.connectToSql()

    # Use connection to execute a query

    cursor = connection.cursor()

    cursor.execute(f"SELECT * FROM MD_FX_RATES;")

    rows = [x for x in cursor]

    columnNames = [x[0] for x in cursor.description]

    # Turn the rows into a json object

    values = []

    for row in rows:

        item = {}

        for prop, val in zip(columnNames, row):

            if isinstance(val, (datetime.date, datetime.datetime)):

                val = val.isoformat()

            item[prop] = val

        values.append(item)

    # Close the connection

    cursor.close()

    connection.close()

    return values

User Data function output

Fabric Data pipeline

Open the Fabric data pipeline à Add the function activity and configure the User Data function settings.

Fabric Data pipeline output

REST API Call Code

from azure.identity import InteractiveBrowserCredential

import requests

import json

from azure.identity import ClientSecretCredential

import pandas as pd   

import io

from pyspark.sql import SparkSession

# Acquire a token

# DO NOT USE IN PRODUCTION.

# Below code to acquire token is to test the GraphQL endpoint and is for the purpose of development only.

# For production, always register an application in a Microsoft Entra ID tenant and use the appropriate client_id and scopes.

# https://learn.microsoft.com/fabric/data-engineering/connect-apps-api-graphql#create-a-microsoft-entra-app

tenant_id = '8bcc'

client_id = '9ee6'

client_secret = '1234'

scope = 'https://analysis.windows.net/powerbi/api/.default'

FUNCTION_URL = 'https://api.fabric.microsoft.com/v1/workspaces/43dd/userDataFunctions/5b8f/functions/query_data_from_tables/invoke'

# Authenticate and get the token

credential = ClientSecretCredential(tenant_id, client_id, client_secret)

token = credential.get_token(scope).token

headers = {

    'Authorization': f'Bearer {token}',

    'Content-Type': 'application/json'

}

try:  

    response = requests.get(FUNCTION_URL, headers=headers)

    response.raise_for_status()

    print(json.dumps(response.json()))

except Exception as e:

    print({"error": str(e)}, 500)

    print(response.headers)

REST API call output