Payam K
08/19/2022, 6:15 PM@task
def make_df(i):
logger = prefect.context.get("logger")
<http://logger.info|logger.info>("Hi from Prefect %s", prefect.__version__)
<http://logger.info|logger.info>("this is the first step")
data = {'Name':['Tom', 'Brad', 'Kyle', 'Jerry'],
'Age':[20, i**2, 2*i, 18*i],
'Height' : [6.1, 5.9, 6.0, 6.1]
}
df = pd.DataFrame(data)
return df
How should I design my work to run 5 parallel task in ECS cluster?Anna Geller
08/19/2022, 6:33 PMPayam K
08/19/2022, 7:18 PMAnna Geller
08/19/2022, 8:41 PMPayam K
08/19/2022, 8:45 PMAnna Geller
08/19/2022, 9:01 PM