https://prefect.io
Join Slack
Hi, I am trying to optimize deployments to prefect cloud. I am creating from a github action 6 deplo...
# prefect-cloud
t
Hi, I am trying to optimize deployments to prefect cloud. I am creating from a github action 6 deployments and 8 blocks (aws credentials, s3 bucket, 6 ecs task blocks), using Python API. Currently this takes around 12 mins to deploy, which is too slow for us, as we will be adding a lot more. The storage block is an S3 bucket, infrastructure block for every flow is an ECSTask. Does anyone has an idea why it's slow and how can we optimize this?
r
We use gh actions and it takes nowhere near this long. Are they sequential or do you run them in parallel via a matrix...can you share any of the action yml.
✅ 1
b
+1 to this @Tibs - I run all my 
prefect build apply
commands concurrently with the 
&
command but for a repo with 20ish deployments it can take about 10 minutes per environment ( prod | staging ) to deploy. It has been a massive time suck. Would be great to get a batch deploy or something of the kind...
t
it is a sequential script in our case, using a python script, I can look to change to a parallel execution, however, as per @Ben Muller's point, still would be slow when we get to more deployments.
r
if you use a matrix they can all run in parallel (depending on node availability) https://docs.github.com/en/actions/using-jobs/using-a-matrix-for-your-jobs
we have a deployment per flow and can choose to deploy only flows that have changed or a separate workflow for everything
t
how do you detect what are the flows that have changes?
r
that gets me a list of flow folders that have changed which is the matrix for parallel deploys
I too was worried about what happens when we have dozens of flows so tackled this early
b
This would assume there are no other modules of shared code in the repo and all the logic lives within the flows folder.
r
on build we copy down a shared module folder that geta deployed with the flow, for development we symlink
👍 1
we found it preferable over packaging them up
a
you are most likely uploading all code to S3 during build? there is no reason for deployment build to take that long regardless of parallel or not, unless you keep uploading everything
t
@Anna Geller yes, I think this is the case
a
you could follow the same approach I did - only upload once with the maintenance flow and --skip-upload in the matrix build command
t
@Anna Geller But when there are changes in the flows, shouldn't files be reloaded to S3 to reflect the changes, so that the agent picks up the updated version? I might be misunderstanding something here
a
btw in the coming weeks I'll try to make that more modular in a separate branch, might be easier to use then
t
@Anna Geller cool, seems like I have a lot to modify on my side, thanks a lot for sharing!
🙌 1
b
So @Anna Geller what you're saying is that if I have 10 flows I can skip upload for 9 of them and everything will work fine?
a
I only do upload for a maintenance flow that is not in the flows/ directory - the normal build for all flows/ iterated over in a matrix doesn't upload to S3
and yes, you could even upload the flows manually to S3 via: aws s3 sync yourproject/ s3://yourbucket/yourproject/ and this would also work
but the approach I shared seemed the easiest to me - we always upload to make sure the project is up to date and deployments are only created for new/modified flows so that e.g. if you add new parameters to your flow function, the parameter gets properly updated on a deployment
b
I actually bake all my code into a custom image anyway. Is there a way to tell prefect that it's there?
a
yes, 100%! you would set --path e.g. 
--path /opt/prefect
having flows baked into Docker image is fully supported and totally encouraged - LMK if sth doesn't work, I can investigate
b
Path on my EcsTask block? And then I don't need to upload anything in my deployments?
a
spot on!
the path would be set on the build command
b
Interesting. I'll give it a go today and report back. That would be enormous for us.
🙌 1
Hey @Anna Geller - just looking at this now - you say it would be set on the build command. Do you mean the 
save
command ? I can not see a build command on the 
ECSTask
block? Or do you mean the path on the 
prefect deployment build
command ?
a
on build
Copy code
prefect deployment build myflow.py:myflow -ib ecs-task/default --path /opt/flows -n default -a
b
gotcha
thanks
I also have to now remove the 
--storage-block
argument or it will look in s3 by default, yeah?
After following the instructions I had no luck. Kept getting errors when running the flow:
Copy code
Flow could not be retrieved from deployment.
Traceback (most recent call last):
  File "/usr/local/lib/python3.10/site-packages/prefect/engine.py", line 262, in retrieve_flow_then_begin_flow_run
    flow = await load_flow_from_flow_run(flow_run, client=client)
  File "/usr/local/lib/python3.10/site-packages/prefect/client/utilities.py", line 47, in with_injected_client
    return await fn(*args, **kwargs)
  File "/usr/local/lib/python3.10/site-packages/prefect/deployments.py", line 166, in load_flow_from_flow_run
    await storage_block.get_directory(from_path=deployment.path, local_path=".")
  File "/usr/local/lib/python3.10/site-packages/prefect/filesystems.py", line 143, in get_directory
    copytree(from_path, local_path, dirs_exist_ok=True)
  File "/usr/local/lib/python3.10/shutil.py", line 556, in copytree
    with os.scandir(src) as itr:
FileNotFoundError: [Errno 2] No such file or directory: '/opt/flows'
For the record it only saved 525 seconds ~ in deploy time per environment ( I am deploying 12 flows ) The costly part seems to be the generation of the yml file in the 
build
command
would I not need to prepend the flow file location to each of the 
--path
options ? 
--path {work_dir}/flows/my_flow
?
t
So, I was able to take make the process faster by running the maintenance step and skip_uploads for the other flows. Although I did this using python scripts instead of doing it in the github actions template. Also caching python dependencies in the github workflow helped.
3 Views
Open in Slack
PreviousNext
Powered by

Prefect Community

Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.

Powered by