-
Notifications
You must be signed in to change notification settings - Fork 62
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Cloudflare R2 Integration #856
Conversation
This change introduces an API for Skyplane Broadcast Todos: - [x] Fix provisioning in BroadcastDataplane - Reuse provision loop via inheritance - Move `_start_gateway` to a class method and override it - Adapt broadcast to use `bound_nodes` - [x] Add BroadcastCopyJob (ideally extend CopyJob) - [x] Update tracker to monitor broadcast jobs - [x] Add multipart support - [x] Fix dependency issue via adding dockerfile and bc_requirements - [x] Integrate with gateway and test the monitoring side Co-authored-by: Paras Jain <[email protected]> Co-authored-by: Sarah Wooders <[email protected]>
|
||
# regions that are sinks for specific region tag | ||
# TODO: should eventualy map bucket to list of instances | ||
sinks = [n for nodes in self.dataplane.topology.sink_instances(region_tag).values() for n in nodes] |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I'm a bit confused as to what this is doing?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is grabbing all the instances that are writing to a bucket in region_tag
- previously the sink instances were defined as the instances in the sink region, but that doesn't hold for one-sided transfers
skyplane init
to setup Cloudflare R2 access keys (stored inSkyplaneConfig
)region_tag
of destinations is mapped to instance regions, since with one-sided transfers the destination region may not correspond to the sink instance regionTodo