Channels
pacc-may-31-2023
prefect-ai
pacc-clearcover-june-12-2023
marvin-in-the-wild
data-ecosystem
geo-israel
pacc-june-14-2023
geo-japan
prefect-cloud
ppcc-may-16-2023
prefect-azure
prefect-docker
prefect-recipes
gratitude
geo-nyc
geo-bay-area
geo-boston
geo-london
geo-dc
geo-chicago
geo-berlin
geo-texas
geo-seattle
geo-colorado
prefect-community
data-tricks-and-tips
prefect-aws
prefect-gcp
introductions
find-a-prefect-job
prefect-dbt
random
events
ask-marvin
show-us-what-you-got
prefect-getting-started
prefect-integrations
prefect-contributors
best-practices-coordination-plane
announcements
prefect-server
prefect-ui
prefect-kubernetes
Powered by
Title
d
Daniel Conway
10/06/2022, 6:57 PM
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(' --------------------------------------- ')
:marvin-duck: 1
🚀 1
a
Anna Geller
10/07/2022, 10:43 AM
thanks for sharing your flow!
3 Views
#show-us-what-you-got
Join Slack