latch_cli.services.cp package#
Submodules#
latch_cli.services.cp.autocomplete module#
latch_cli.services.cp.config module#
- class latch_cli.services.cp.config.Progress(value)[source]#
Bases:
enum.Enum
An enumeration.
- none = 'none'#
- total = 'total'#
- tasks = 'tasks'#
- class latch_cli.services.cp.config.CPConfig(progress: latch_cli.services.cp.config.Progress, verbose: bool)[source]#
Bases:
object
- progress: latch_cli.services.cp.config.Progress#
latch_cli.services.cp.download module#
- class latch_cli.services.cp.download.DownloadJob(signed_url: str, dest: pathlib.Path)[source]#
Bases:
object
- dest: pathlib.Path#
- latch_cli.services.cp.download.download(src: str, dest: pathlib.Path, config: latch_cli.services.cp.config.CPConfig)[source]#
- latch_cli.services.cp.download.download_file(job: latch_cli.services.cp.download.DownloadJob, progress_bars: latch_cli.services.cp.progress.ProgressBars) int [source]#
latch_cli.services.cp.exceptions module#
- exception latch_cli.services.cp.exceptions.PathResolutionError[source]#
Bases:
ValueError
latch_cli.services.cp.glob module#
latch_cli.services.cp.ldata_utils module#
- class latch_cli.services.cp.ldata_utils.LDataNodeType(value)[source]#
-
An enumeration.
- account_root = 'account_root'#
- dir = 'dir'#
- obj = 'obj'#
- mount = 'mount'#
- link = 'link'#
- class latch_cli.services.cp.ldata_utils.LdataNodePayload[source]#
Bases:
TypedDict
- finalLinkTarget: latch_cli.services.cp.ldata_utils.FinalLinkTargetPayload#
- class latch_cli.services.cp.ldata_utils.NodeData(id: str, name: str, type: latch_cli.services.cp.ldata_utils.LDataNodeType, is_parent: bool)[source]#
Bases:
object
- class latch_cli.services.cp.ldata_utils.GetNodeDataResult(acc_id: str, data: Dict[str, latch_cli.services.cp.ldata_utils.NodeData])[source]#
Bases:
object
- data: Dict[str, latch_cli.services.cp.ldata_utils.NodeData]#
- latch_cli.services.cp.ldata_utils.get_node_data(*remote_paths: str, allow_resolve_to_parent: bool = False) latch_cli.services.cp.ldata_utils.GetNodeDataResult [source]#
- class latch_cli.services.cp.ldata_utils.LdataResolvePathData[source]#
Bases:
TypedDict
- childLdataTreeEdges: latch_cli.services.cp.ldata_utils.ChildLdataTreeEdges#
- class latch_cli.services.cp.ldata_utils.TeamInfosByOwnerId[source]#
Bases:
TypedDict
- nodes: List[latch_cli.services.cp.ldata_utils.Team]#
- class latch_cli.services.cp.ldata_utils.UserInfoByAccountId[source]#
Bases:
TypedDict
- teamMembersByUserId: latch_cli.services.cp.ldata_utils.TeamMembersByUserId#
- teamInfosByOwnerId: latch_cli.services.cp.ldata_utils.TeamInfosByOwnerId#
- class latch_cli.services.cp.ldata_utils.LdataS3MountAccessProvensByGeneratedUsing[source]#
Bases:
TypedDict
- nodes: List[latch_cli.services.cp.ldata_utils.Bucket]#
- class latch_cli.services.cp.ldata_utils.LdataS3MountConfiguratorRolesByAccountIdNode[source]#
Bases:
TypedDict
- ldataS3MountAccessProvensByGeneratedUsing: latch_cli.services.cp.ldata_utils.LdataS3MountAccessProvensByGeneratedUsing#
- class latch_cli.services.cp.ldata_utils.LdataS3MountConfiguratorRolesByAccountId[source]#
Bases:
TypedDict
- class latch_cli.services.cp.ldata_utils.AccountInfoCurrent[source]#
Bases:
TypedDict
- userInfoByAccountId: latch_cli.services.cp.ldata_utils.UserInfoByAccountId#
- ldataS3MountConfiguratorRolesByAccountId: latch_cli.services.cp.ldata_utils.LdataS3MountConfiguratorRolesByAccountId#
latch_cli.services.cp.main module#
latch_cli.services.cp.path_utils module#
latch_cli.services.cp.progress module#
- class latch_cli.services.cp.progress.ProgressBars(num_task_bars: int, *, show_total_progress: bool = True, verbose: bool = False)[source]#
Bases:
object
- latch_cli.services.cp.progress.get_free_index(progress_bars: latch_cli.services.cp.progress.ProgressBars)[source]#
latch_cli.services.cp.remote_copy module#
latch_cli.services.cp.upload module#
- class latch_cli.services.cp.upload.UploadJob(src: pathlib.Path, dest: str)[source]#
Bases:
object
- src: pathlib.Path#
- latch_cli.services.cp.upload.upload(src: str, dest: str, config: latch_cli.services.cp.config.CPConfig)[source]#
- class latch_cli.services.cp.upload.StartUploadReturnType(upload_id: str, urls: List[str], part_count: int, part_size: int, src: pathlib.Path, dest: str)[source]#
Bases:
object
- src: pathlib.Path#
- latch_cli.services.cp.upload.start_upload(src: pathlib.Path, dest: str, progress_bars: Optional[latch_cli.services.cp.progress.ProgressBars] = None, throttle: Optional[latch_cli.services.cp.throttle.Throttle] = None, latency_q: Optional[LatencyQueueType] = None) Optional[latch_cli.services.cp.upload.StartUploadReturnType] [source]#
- class latch_cli.services.cp.upload.CompletedPart(src: pathlib.Path, etag: str, part_number: int)[source]#
Bases:
object
- src: pathlib.Path#
- latch_cli.services.cp.upload.upload_file_chunk(src: pathlib.Path, url: str, part_index: int, part_size: int, progress_bars: latch_cli.services.cp.progress.ProgressBars, pbar_index: Optional[int], parts_by_source: Optional[PartsBySrcType] = None, upload_id: Optional[str] = None, dest: Optional[str] = None) latch_cli.services.cp.upload.CompletedPart [source]#
- latch_cli.services.cp.upload.end_upload(dest: str, upload_id: str, parts: List[latch_cli.services.cp.upload.CompletedPart], progress_bars: Optional[latch_cli.services.cp.progress.ProgressBars] = None)[source]#