Skip to content

Instantly share code, notes, and snippets.

@ishritam
Created June 20, 2021 11:25
Show Gist options
  • Save ishritam/440eedf87b021c1f2f4b452ca6ec32b1 to your computer and use it in GitHub Desktop.
Save ishritam/440eedf87b021c1f2f4b452ca6ec32b1 to your computer and use it in GitHub Desktop.
Zalando ETL Load
def load_data(path: str, ti) -> None:
data = ti.xcom_pull(key='transformed_data', task_ids=['transform_data'])
data_df = pd.DataFrame(data[0])
data_df.to_csv(path, index=None)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment