James Phoenix
10/22/2020, 3:56 PMRaphaël Riel
10/22/2020, 5:09 PM# define Prefect flow
with Flow("Test Flow", schedule=schedule) as flow:
realtor_data = extract()
houston_realtor_data = transform()
load_to_database = load()
flow_state = flow.run()
result = flow_state.result[houston_realtor_data].result
print(result)
log_stdout=True
.
@task
def extract(log_stdout=True):
# download and return a list of all texas realtors
print(result)
return result
Chris White
James Phoenix
10/22/2020, 5:41 PMChris White
James Phoenix
10/22/2020, 5:57 PM