xyzz
04/26/2022, 11:20 AMAnna Geller
xyzz
04/26/2022, 1:46 PMAnna Geller
xyzz
04/28/2022, 7:35 AMAnna Geller
xyzz
04/28/2022, 1:04 PMAnna Geller
@sync_compatible
@inject_client
async def create_deployment(
self, client: OrionClient, validate: bool = True
) -> UUID:
"""
Create a deployment from the current specification.
"""
if validate:
await self.validate()
flow_id = await client.create_flow(self.flow)
# Read the flow file
with fsspec.open(self.flow_location, "rb") as flow_file:
flow_bytes = flow_file.read()
davzucky
04/28/2022, 1:53 PMxyzz
04/29/2022, 9:41 AMAnna Geller