Kha Nguyen
07/21/2022, 3:25 PMKevin Kho
Kha Nguyen
07/21/2022, 3:56 PMKevin Kho
Kha Nguyen
07/21/2022, 4:00 PMKevin Kho
Kha Nguyen
07/21/2022, 4:03 PMKevin Kho
Kha Nguyen
07/21/2022, 4:05 PMKevin Kho
Kha Nguyen
07/21/2022, 4:12 PM@flow
def forecast(customer: str, dimensions: List[str], metrics: List[str]) -> pd.DataFrame:
data = load_data_task()
results = [forecast_task(df) for df in data]
return results
Now, I have a web service that when I receive a new forecast setup, then I would invoke
deployment = Deployment(flow=forecast, params=params)
await deployment.create()
The deployment should be saved to S3.
I have 1000+ deployments like this, and lets say I make changes to the forecast
flow, or to the tasks, then how can this update be propagated? Considering that I am using Prefect Cloud.