get.py

# + tags=["parameters"]
# declare a list tasks whose products you want to use as inputs
upstream = None

# -

import glob
import pandas as pd



# +
upstream = ['raw']
product = None
# -


print('hello')

raw.py

import pandas as pd
import numpy as np

upstream = None
product = None

for i in range(10):
    data = np.random.random((10,10))
    pd.DataFrame(data).to_csv(f'./test_products/rand_{i}.csv')

test_products is the path to the directory