[Spot/Serve] Optimize the translation of filemounts #4016
Conversation
warrickhe
changed the title
There was a problem hiding this comment.
Thanks for adding this feature @warrickhe ! It would be really helpful for us to reduce the file upload latency. Left some discussion ; )
There was a problem hiding this comment.
Thanks for submitting this PR @warrickhe! This is awesome.
Haven't looked into the code, but just a reminder in case we have missed it in our implementation: our original behavior for rsync will exclude files specified with .gitignore. Just curious, if we have this behavior in our compression logic as well. : )
Good point! I will modify the code along with Tian's suggestion to maintain the original behaviour . |
There was a problem hiding this comment.
@warrickhe Thanks for the prompt fix! I tried this with sky serve (examples/serve/http_server/task.yaml, I forcefully enabled the compress feature.) but seems like i got a lot of zipped files in the cloud bucket, while expected to only get one. Not sure if it has anything to do with the other file mounts. Could you please take a look on this?
I 10-08 11:51:15 backend_utils.py:1343] Syncing (to 1 node): /tmp/service-task-new-http-2ok7ehj6 -> ~/.sky/serve/new_http/task.yaml.tmp
I 10-08 11:51:16 backend_utils.py:1343] Syncing (to 1 node): /tmp/tmp3oxekj8x -> ~/.sky/serve/new_http/config.yaml
I 10-08 11:51:16 backend_utils.py:1343] Syncing (to 1 node): /home/txia/.sky/catalogs/v5/aws/images.csv -> ~/.sky/catalogs/v5/aws/images.csv
I 10-08 11:51:16 backend_utils.py:1343] Syncing (to 1 node): /home/txia/.sky/catalogs/v5/aws/az_mappings-6d23a727.csv -> ~/.sky/catalogs/v5/aws/az_mappings-6d23a727.csv
I 10-08 11:51:17 backend_utils.py:1343] Syncing (to 1 node): /home/txia/.sky/catalogs/v5/azure/images.csv -> ~/.sky/catalogs/v5/azure/images.csv
I 10-08 11:51:17 backend_utils.py:1343] Syncing (to 1 node): /home/txia/.sky/catalogs/v5/azure/vms.csv -> ~/.sky/catalogs/v5/azure/vms.csv
I 10-08 11:51:17 backend_utils.py:1343] Syncing (to 1 node): /home/txia/.sky/catalogs/v5/azure/az_ml_vms.csv -> ~/.sky/catalogs/v5/azure/az_ml_vms.csv
I 10-08 11:51:18 backend_utils.py:1343] Syncing (to 1 node): /home/txia/.sky/catalogs/v5/gcp/vms.csv -> ~/.sky/catalogs/v5/gcp/vms.csv| @@ -959,7 +959,8 @@ def sync_storage_mounts(self) -> None: | |||
| if len(storage.stores) == 0: | |||
| store_type, store_region = self._get_preferred_store() | |||
| self.storage_plans[storage] = store_type | |||
| storage.add_store(store_type, store_region) | |||
| is_workdir = storage.name.startswith('skypilot-workdir') | |||
There was a problem hiding this comment.
I think we should have a config for toggle this feature. cc @Michaelvll for a look here?
Could you show how you forcefully enabled compression in so I may try to replicate this issue? It's seems like that my code is trying to compress every file individually, which leads me to believe that the way you forcefully enable compression may have been incorrect. My code could also be going a bit haywire, but it's hard to say without access to the bucket and workspace. What is confusing is how there are 20 files when the workdir should only have 2, I will try to dig into this |
I hardcode the following 2 if conditions to 
|
This shouldn't be right. Not sure how you're getting compressed files at all, the second True will turn off all compression. We enable compression only if num_files(self.source, excluded_list) > 10, so you actually want to set that to False. |
(Work in Progress) PR to fix #3188. Added compression to local file -> intermediate bucket translation. Still working on the decompression side.
Tested (run the relevant ones):
bash format.shpytest tests/test_smoke.pypytest tests/test_smoke.py::test_fill_in_the_nameconda deactivate; bash -i tests/backward_compatibility_tests.sh