Jeff Katz
01/11/2024, 9:56 PM@flow(name="extract_and_write")
def extract_and_write(playlist_id):
playlist_tracks = get_playlist_tracks(playlist_id)
# fill in remainder of flow here
selected_tracks = extract_tracks_info(playlist_tracks, playlist_id)
write_to_csv(selected_tracks)
deployment = Deployment.build_from_flow(
name="sample_deployment",
flow=extract_and_write,
version=1,
schedule=schedule,
is_schedule_active=True,
work_queue_name="default",
parameters=parameters,
entrypoint="./spotify_workflow.py:extract_and_write",
)