Sunjay
10/26/2022, 2:36 PMKhuyen Tran
10/26/2022, 3:17 PMvalidate_parameters=False
Sunjay
10/27/2022, 8:44 AMKhuyen Tran
10/27/2022, 3:45 PMSunjay
10/28/2022, 1:42 PM@flow(name='prod_pagespeed_metrics')
def pagespeed_metrics(columns:list, device_type:str='mobile', table_name:str='metrics', schema_name:str='dl_pagespeed_api', api_url:str='<https://www.googleapis.com/pagespeedonline/v5/runPagespeed',url_file_path:str='files/page_speed_urls.csv>'):
url_list = get_url_list(url_file_path)
category = 'performance'
metrics = transform_pagespeed_api(url_list=url_list,
device_type=device_type,
category=category,
api_key=google_pagespeed_api_key.get(),
api_url=api_url)
df_to_redshift(metrics, redshift_user.get(), redshift_password.get(),
table_name, redshift_db.get(), schema_name, redshift_host.get())
Khuyen Tran
10/28/2022, 3:46 PMfrom prefect import task, flow
@flow
def test_flow(l: list = [1, 2, 3]):
assert isinstance(l, list)
if __name__ == "__main__":
test_flow()
and changed the value of the parameter when running the deployment.
It worked fine for me. I wonder if you change the value of the parameter through deployment?Sunjay
11/01/2022, 8:02 AM