Simple Kubeflow component funtion

function.py

def bigquery_to_csv(filter_param: str ="50"):
    #a. importing dependencies
    from google.cloud import bigquery
    import google.auth
    
    #b. creating credentials
    creds, project = google.auth.default()
    client = bigquery.Client(project='demo-project', credentials=creds)

    #c. preforming query
    query =     """
            SELECT * FROM `demo-project.health.disease` WHERE age>{}
    """.format(filter_param)
    dataframe = client.query(query).to_dataframe()