with Flow("hello-world"):
task1 = hello_task()
task2 = test(task1)
with Flow("Multiple Flow"):
db_table=create_table()
raw=get_complete_date()
parsed=parse_complaint_data(raw)
populated_table= store_complaints(parsed)
populated_table.set_upstream(db_table)
from prefect import Flow
from prefect.tasks.prefect import StartFlowRun
data_engineering_flow = StartFlowRun(flow_name="hello-world",
project_name='ETL - Prefect',
wait=True)
data_science_flow = StartFlowRun(flow_name="Multiple Flow",
project_name='ETL - Prefect',
wait=True)
with Flow("main-flow") as flow:
result = data_science_flow(upstream_tasks=[data_engineering_flow])
flow.run()
flow.register(project_name="ETL - Prefect")
I am facing some issues in flow after executing the code we can able to
see flow in UI but We couldn't see task results and also its taking lots of time for processing.. can anyone help me out this