Slackbot
03/01/2022, 1:54 PMMrFiat124Spider
03/01/2022, 1:55 PMMrFiat124Spider
03/01/2022, 2:04 PMEduardo
MrFiat124Spider
03/01/2022, 2:34 PM# %% tags=["parameters"]
upstream = ["raw"]
product = None
# %%
df = pd.read_csv(upstream['get']['data'])
MrFiat124Spider
03/01/2022, 2:35 PMMrFiat124Spider
03/01/2022, 2:37 PMEduardo
Eduardo
Eduardo
MrFiat124Spider
03/01/2022, 2:44 PMEduardo
MrFiat124Spider
03/01/2022, 2:46 PMMrFiat124Spider
03/01/2022, 2:47 PMMrFiat124Spider
03/01/2022, 2:48 PMMrFiat124Spider
03/01/2022, 2:49 PMMrFiat124Spider
03/01/2022, 2:50 PMMrFiat124Spider
03/01/2022, 2:51 PMMrFiat124Spider
03/01/2022, 2:52 PMMrFiat124Spider
03/01/2022, 2:53 PMMrFiat124Spider
03/01/2022, 2:53 PMMrFiat124Spider
03/01/2022, 2:53 PMtasks:
# this is a sql script task
- source: raw.sql
product: [schema, name, table]
# ...
# this is a function task
# "my_functions.clean" is equivalent to: from my_functions import clean
- source: my_functions.clean
product: output/clean.csv
# this is a script task (notebooks work the same)
- source: plot.py
product:
# scripts always generate a notebook (more on this in the next section)
nb: output/plots.ipynb
MrFiat124Spider
03/01/2022, 2:53 PMMrFiat124Spider
03/01/2022, 2:53 PMMrFiat124Spider
03/01/2022, 2:54 PMMrFiat124Spider
03/01/2022, 2:57 PMMrFiat124Spider
03/01/2022, 2:58 PMEduardo
Eduardo
Eduardo
MrFiat124Spider
03/01/2022, 3:19 PMMrFiat124Spider
03/01/2022, 3:20 PM