from prefect import flow, task from prefect import flow, task import yfinance as yf from time import sleep from random import randint from pandas import DataFrame from datetime import timedelta @task(retries = 5, retry_delay_seconds = 5) def getData(ticker): print('before: ', ticker) df = yf.download(ticker) print('after ') return df @task def displayTicker(df:DataFrame): print(df) @flow def getTickerData(symbols): print('in getTickerData') dfs = getData.map(symbols) print('After getTickerData') #displayTicker(dfs) return dfs if name == "__main__": print(' --------------------------------------- ') print(' --------------------------------------- ') ticker = ['DE','GE','IBM','CSCO'] stockTable = getTickerData(ticker) print ('*** ', ticker, ' * ') print (stockTable) print(' --------------------------------------- ') print(' --------------------------------------- ')

thanks for sharing your flow!