Joan Gil
01/31/2023, 2:31 PMfor sub_deployments in flows:
await asyncio.gather(
*[deploy_flow(deployment_config) for deployment_config in sub_deployments]
)
async def deploy_flow(deployment_config):
flow = deployment_config.get("flow")
print(f"deploying : {flow.name}")
await Deployment.build_from_flow(
...
storage=gcs_block,
apply=True,
)
print(f"applied deployment: {flow.name}")
I get the two flows deploying at the same time, but the first one always finishes first, and I have to wait for bout 2 minutes until the 2nd one finishes and it’s always like that, which tells me that something’s blocking the 2nd flow from being deployed/registered with the API.