Mateo Merlo
05/11/2022, 4:31 PMAnna Geller
Mateo Merlo
05/11/2022, 5:35 PMMateo Merlo
05/11/2022, 5:38 PMAnna Geller
Mateo Merlo
05/11/2022, 5:47 PMMateo Merlo
05/11/2022, 5:50 PMAnna Geller
Mateo Merlo
05/11/2022, 8:07 PM@task
def extract_and_load(dataset: str) -> None:
logger = prefect.context.get("logger")
file = f"<gs://football_transfers/transfers/{dataset}>"
df = pd.read_csv(file)
<http://logger.info|logger.info>("Dataset %s with %d rows loaded to DB", dataset, len(df))
Anna Geller
Mateo Merlo
05/12/2022, 7:37 AM