Chu
07/23/2022, 8:38 PMflow.run_config = KubernetesRun()
)
2. Where can I attach LocalDaskExecutor? Only to the parent flow? (Maybe for flow A, B, I just set their parameters using unmapped()
function?)
3. Is there a way for me to test my project locally (to make sure the design works as wished) without registering every flow to the Cloud?
4. (Optional) for my use case, is there a better design to achieve my goals? Since I’m quite new to Prefect, but really astonished by its cool functionality, maybe there is some place I can make great improvements for our company
Thanks! It’s a long question, but really appreciate for any help!Anna Geller
07/23/2022, 9:46 PMChu
07/23/2022, 11:57 PMwith Flow("backfilling_flow") as flow:
start_date = Parameter('start_date', default='2022-01-05')
end_date = Parameter('end_date', default='2022-01-06')
fetch_data(start_date=start_date, end_date=end_date)
This approach will backfire as long as the default values are used.”Anna Geller
07/24/2022, 1:11 AM