当地¶

这包含可用于运行 TorchX 的 TorchX 本地调度器组件。

torchx.schedulers.local_scheduler 类。LocalScheduler（session_name： str， image_provider_class： Callable[[Mapping[str， Optional[Union[str， int， float， bool， List[str]]]]]，torchx.schedulers.local_scheduler。ImageProvider]，cache_size：int = 100，extra_paths：可选[List[str]] = 无）[来源]¶

基地：torchx.schedulers.api.Scheduler

在 localhost 上调度。容器被建模为进程和容器的某些不相关的属性或者无法对 localhost 强制执行 runs。被忽略的属性：

资源要求
资源限制实施
重试策略
重试计数（不支持重试）
部署首选项

调度器支持在接收 SIGTERM 或 SIGINT 时进行孤立进程清理。调度程序将终止生成的进程。

这是通过 scheduler local_cwd 公开的。

local_cwd 相对于当前工作运行目录下，并忽略 images 字段以加快迭代和测试速度目的。

注意

孤立项清理仅在从主线程实例化 LocalScheduler 时起作用。

配置选项

    usage:
        [log_dir=LOG_DIR],[prepend_cwd=PREPEND_CWD],[auto_set_cuda_visible_devices=AUTO_SET_CUDA_VISIBLE_DEVICES]

    optional arguments:
        log_dir=LOG_DIR (str, None)
            dir to write stdout/stderr log files of replicas
        prepend_cwd=PREPEND_CWD (bool, False)
            if set, prepends CWD to replica's PATH env var making any binaries in CWD take precedence over those in PATH
        auto_set_cuda_visible_devices=AUTO_SET_CUDA_VISIBLE_DEVICES (bool, False)
            sets the `CUDA_AVAILABLE_DEVICES` for roles that request GPU resources. Each role replica will be assigned one GPU. Does nothing if the device count is less than replicas.

兼容性

注意

由于调度程序差异，本地运行的作业在以下情况下可能无法工作由于网络或软件依赖性，使用不同的调度程序。

特征	计划程序支持
获取日志	✔️
分布式作业	LocalScheduler 支持多个副本，但所有副本都将在本地主机上执行。
取消作业	✔️
描述任务	✔️
工作区 / 修补	部分支持。LocalScheduler 从本地目录中，但不支持编程工作区。
坐骑	❌

close（） → None [来源]¶

仅适用于具有本地状态的调度器！关闭调度程序释放任何已分配的资源。关闭后，scheduler 对象被视为不再有效，并且对对象调用的任何方法导致未定义的行为。

此方法不应引发异常，并且允许调用对同一对象进行多次作。

注意

仅对具有本地状态的调度程序实现进行覆盖 (). Scheduler 只需包装远程 scheduler 的 Client 端就不需要实现此方法。torchx/schedulers/local_scheduler.py

describe（app_id： str） → 可选[torchx.schedulers.api.DescribeAppResponse][来源]¶

描述指定的应用程序。

返回: AppDef 描述，或者应用程序不存在。None

log_iter（app_id： str， role_name： str， k： int = 0， regex：可选[str] = 无，因为：可选[datetime.datetime] = 无，直到：可选[datetime.datetime] = 无，should_tail：bool = False，流：可选[torchx.schedulers.api.Stream] = None） → Iterable[str][源代码]¶

返回 . 迭代器 ends end 所有符合条件的日志行都已读取。k``th replica of the ``role

如果调度程序支持基于时间的游标获取日志行对于自定义时间范围，则，字段为 honored，否则将被忽略。未指定，相当于获取所有可用的日志行。如果是 empty，则迭代器的行为类似于，跟在日志输出之后直到作业达到 END 状态。sinceuntilsinceuntiluntiltail -f

构成日志的确切定义特定于计划程序。一些调度器可能会将 stderr 或 stdout 视为日志，其他人可能会读取日志从日志文件中。

行为和假设：

如果在不存在的应用程序上调用，则生成 undefined-behavior 调用方应在调用此方法之前检查应用是否存在 using。exists(app_id)
不是有状态的，使用相同的参数调用此方法两次返回一个新的迭代器。先前迭代进度丢失。
并不总是支持对数拖尾。并非所有调度程序都支持 live 日志迭代（例如，在应用程序运行时跟踪日志）。指 Iterator 行为的特定 scheduler 文档。

3.1 如果调度器支持 log-tailing，应该对其进行控制: by''should_tail'' 参数。

不保证日志保留。有可能到这个方法调用时，底层调度程序可能已经清除了日志记录对于此应用程序。如果是这样，此方法将引发任意异常。
如果为 True，则该方法仅引发异常当可访问的日志行已完全耗尽并且应用程序已达到最终状态。例如，如果应用程序卡住并且没有产生任何日志行，然后 iterator 会阻塞，直到应用程序最终被杀死（通过 timeout 或手动），此时它会引发一个 .should_tailStopIterationStopIteration

如果为 False，则当没有更多日志时，该方法将引发。should_tailStopIteration
不需要所有调度程序都支持。
一些调度器可能通过支持 line cursor（例如寻找第 50 个对数行）。__getitem__iter[50]
保留空格，每个新行应包含。自\n
支持交互式进度条返回的行不需要 include 的 m，但随后应打印时不带换行符正确处理回车。\n\r

参数: streams – 要选择的 IO 输出流。其中之一： combined， stdout， stderr. 如果调度程序不支持所选流，它将 throw 一个 ValueError 的 Error。
返回: 指定角色副本的 over log linesIterator
提高: NotImplementedError – 如果调度程序不支持日志迭代

run_opts（） → torchx.specs.api.runopts [来源]¶: 返回计划程序所需的运行配置选项。基本上是 API 的。--helprun

schedule（dryrun_info 的 Package 中：torchx.specs.api.AppDryRunInfo[torchx.schedulers.local_scheduler.PopenRequest]） → str [来源]¶

相同，只是它需要一个 . 鼓励实现者实现此方法，而不是直接实现 since 可以很简单实施者：submitAppDryRunInfosubmitsubmit

dryrun_info = self.submit_dryrun(app, cfg)
return schedule(dryrun_info)

图像提供程序¶

torchx.schedulers.local_scheduler 类。ImageProvider[来源]¶

管理下载和设置 on localhost。这仅在 b2 中是必需的，因为通常真正的调度程序会执行此作代表用户。LocalhostScheduler

抽象 fetch（图片：str） → str [来源]¶: 拉取给定的图像并返回拉取的图像的路径本地主机或空字符串（如果没有 OP）

fetch_role（角色：torchx.specs.api.Role） → str [来源]¶: 与它获取角色的 image 并返回镜像根目录的路径，但它允许此提供程序更新角色。有用当需要在角色上设置其他环境变量时为了遵守图片提供商的获取和管理方式 localhost 上的映像。默认情况下，此方法只是将自。如有必要，请覆盖。fetch(image)fetch(role.image)

get_cwd（图片：str）→可选[str][来源]¶: 返回已挂载的 img 目录的绝对路径。用作工作目录中启动子进程。

get_entrypoint（img_root： str， 角色： torchx.specs.api.Role） → str [来源]¶: 返回入口点的位置。

get_replica_param（img_root： str， 角色： torchx.specs.api.Role， stdout：可选[str] = 无，stderr：可选[str] = 无，组合：可选[str] = 无） → torchx.schedulers.local_scheduler。ReplicaParam [来源]¶: 给定角色 replica 的 specs returns holder 其中包含最终要传递给的参数，以实际调用和运行每个角色的副本。预计为的返回值。由于角色的镜像只需要获取一次（不是每个副本）调用方应为每个角色调用一次方法并为每个 .ReplicaParamsubprocess.Popenimg_rootself.fetch(role.image)fetchrole.num_replicas

torchx.schedulers.local_scheduler 类。CWDImageProvider（cfg： Mapping[str， Optional[Union[str， int， float， bool， List[str]]]）[来源]¶

但是，与 LocalDirectoryImageProvider 类似，它会忽略映像名称和使用当前工作目录作为映像路径。

例：

fetch(Image(name="/tmp/foobar"))返回 os.getcwd（）
fetch(Image(name="foobar:latest"))返回 os.getcwd（）

fetch（图片：str） → str [来源]¶: 拉取给定的图像并返回拉取的图像的路径本地主机或空字符串（如果没有 OP）

get_cwd（图片：str）→可选[str][来源]¶: 返回已挂载的 img 目录的绝对路径。用作工作目录中启动子进程。

get_entrypoint（img_root： str， 角色： torchx.specs.api.Role） → str [来源]¶: 返回入口点的位置。

torchx.schedulers.local_scheduler 类。LocalDirectoryImageProvider（cfg： Mapping[str，可选[Union[str， int， float，布尔， List[str]]]）[来源]¶

将镜像名称解释为本地主机。不 “获取” （例如下载）任何内容。结合使用 with 运行本地二进制文件。LocalScheduler

镜像名称必须是绝对路径，并且必须存在。

例：

fetch(Image(name="/tmp/foobar"))返回/tmp/foobar
fetch(Image(name="foobar"))提高ValueError
fetch(Image(name="/tmp/dir/that/does/not_exist"))提高ValueError

fetch（图片：str） → str [来源]¶

提高: ValueError – 如果图像名称不是绝对目录，并且如果它不存在或不是目录

get_cwd（图片：str）→可选[str][来源]¶: 返回绝对工作目录。用作工作目录中。

get_entrypoint（img_root： str， 角色： torchx.specs.api.Role） → str [来源]¶: 返回角色 entrypoint。当本地调度程序使用 image_type=dir，则 childprocess 工作目录将设置为 img_root。如果 role.entrypoint 是相对路径，则会解析如 img_root/role.entrypoint，如果 role.entryPoint 为绝对路径，它将按规定执行。

参考¶

torchx.schedulers.local_scheduler。create_cwd_scheduler（session_name： str， **kwargs： Any） → torchx.schedulers.local_scheduler。LocalScheduler [来源]¶

torchx.schedulers.local_scheduler 类。LogIterator（app_id： str， regex： str， log_file： str， scheduler： torchx.schedulers.api.Scheduler，should_tail：bool = True）[来源]¶

torchx.schedulers.local_scheduler 类。PopenRequest（app_id： str， log_dir： str， role_params： Dict[str， List[torchx.schedulers.local_scheduler。ReplicaParam]]，role_log_dirs：Dict[str， List[str]]）[来源]¶: 保存参数以为每个角色的每个副本创建一个子流程的应用程序。

torchx.schedulers.local_scheduler 类。ReplicaParam（args： List[str]， env： Dict[str， str]， stdout：可选[str] = 无，stderr：可选[str] = 无，组合：可选[str] = 无，cwd：可选[str] = 无）[源]¶: 保存角色的每个副本的参数。LocalScheduler._popen()

torchx.schedulers.local_scheduler 类。SignalException（msg： str， sigval： signal.信号）[来源]¶: 在运行时，当 torchx 本地调度程序进程时，会引发异常收到终止信号。

当地¶

图像提供程序¶

参考¶

文档

教程

资源