Upgrading wandb 0.13 to 0.14
Unknown0.13.11 → 0.14.2
Fetching 3 releases from GitHub…0 / 3
UnknownUpgrade verdict
DepDelta is still reading the notes for this range, so breaking changes can't be ruled out yet.
In plain terms
- DepDelta is still reading the release notes in this range, so it can't rule out breaking changes yet.
- This page updates as the notes come in.
Must act Still reading release notes
DepDelta is still reading the release notes in this range. This updates as they come in.
API changes
Generated by DepDelta from published Python source. Not mixed with prose notes.
- added:
export Sentry
- added:
class Sentry - added:
constructor Sentry() -> None - added:
method Sentry.configure_scope(settings: Optional[Union[wandb.sdk.wandb_settings.Settings, wandb.sdk.internal.settings_static.SettingsStatic]]=…, process_context: Optional[str]=…) -> None - added:
method Sentry.end_session() -> None - added:
method Sentry.exception(exc: Union[str, BaseException, Tuple[Optional[Type[BaseException]], Optional[BaseException], Optional[TracebackType]], None], handled: bool=…, status: Optional[SessionStatus]=…) -> None - added:
method Sentry.mark_session(status: Optional[SessionStatus]=…) -> None - added:
method Sentry.message(message: str, repeat: bool=…) -> None - added:
method Sentry.reraise(exc: Any) -> None - added:
method Sentry.setup() -> None - added:
method Sentry.start_session() -> None - added:
property Sentry.environment -> str
- added:
export MlflowImporter - added:
export MlflowRun - added:
export get_module
- added:
class Importer(ABC) - added:
class ImporterRun - added:
constructor ImporterRun() -> None - added:
function coalesce(*arg: Any) -> Any - added:
function send_manager(root_dir) - added:
method Importer.download_all_runs() -> Iterable[ImporterRun] - added:
method Importer.import_all(overrides: Optional[Dict[str, Any]]=…) -> None - added:
method Importer.import_all_parallel(overrides: Optional[Dict[str, Any]]=…, **pool_kwargs: Any) -> None - added:
method Importer.import_one(run: ImporterRun, overrides: Optional[Dict[str, Any]]=…) -> None - added:
method ImporterRun.artifacts() -> Optional[Iterable[Tuple[Name, Path]]] - added:
method ImporterRun.config() -> Dict[str, Any] - added:
method ImporterRun.cpus_used() -> Optional[int] - added:
method ImporterRun.cuda_version() -> Optional[str] - added:
method ImporterRun.display_name() -> str - added:
method ImporterRun.entity() -> str - added:
method ImporterRun.executable() -> Optional[str] - added:
method ImporterRun.gpus_used() -> Optional[str] - added:
method ImporterRun.host() -> Optional[str] - added:
method ImporterRun.job_type() -> Optional[str] - added:
method ImporterRun.memory_used() -> Optional[int] - added:
method ImporterRun.metrics() -> List[Dict[str, float]] - added:
method ImporterRun.notes() -> Optional[str] - added:
method ImporterRun.os_version() -> Optional[str] - added:
method ImporterRun.program() -> Optional[str] - added:
method ImporterRun.project() -> str - added:
method ImporterRun.python_version() -> Optional[str] - added:
method ImporterRun.run_group() -> Optional[str] - added:
method ImporterRun.run_id() -> str - added:
method ImporterRun.runtime() -> Optional[int] - added:
method ImporterRun.start_time() -> Optional[int] - added:
method ImporterRun.summary() -> Dict[str, float] - added:
method ImporterRun.tags() -> Optional[List[str]] - added:
method ImporterRun.username() -> Optional[str] - added:
variable Name - added:
variable Path
- added:
class MlflowImporter(Importer) - added:
class MlflowRun(ImporterRun) - added:
constructor MlflowImporter(mlflow_tracking_uri, mlflow_registry_uri=…, wandb_base_url=…) -> None - added:
constructor MlflowRun(run, mlflow_client) - added:
method MlflowImporter.download_all_runs() -> Iterable[MlflowRun] - added:
method MlflowImporter.import_one(run: ImporterRun, overrides: Optional[Dict[str, Any]]=…) -> None - added:
method MlflowRun.artifacts() - added:
method MlflowRun.config() - added:
method MlflowRun.display_name() - added:
method MlflowRun.entity() - added:
method MlflowRun.git() - added:
method MlflowRun.job_type() - added:
method MlflowRun.metrics() - added:
method MlflowRun.notes() - added:
method MlflowRun.project() - added:
method MlflowRun.run_group() - added:
method MlflowRun.run_id() - added:
method MlflowRun.runtime() - added:
method MlflowRun.start_time() - added:
method MlflowRun.summary() - added:
method MlflowRun.tags() - added:
variable mlflow
- added:
async method Api.upload_file_retry_async(*args, **kwargs) - added:
method Api.entity_is_team(*args, **kwargs) - added:
method Api.fail_run_queue_item(*args, **kwargs) - added:
method Api.fail_run_queue_item_introspection(*args, **kwargs)
- added:
function parse_backend_error_messages(response: requests.Response) -> List[str]
- changed:
method Job.call(config, project=…, entity=…, queue=…, resource=…, resource_args=…, cuda=…, project_queue=…) → method Job.call(config, project=…, entity=…, queue=…, resource=…, resource_args=…, project_queue=…)
- changed:
function launch(uri, job, entry_point, git_version, args_list, name, resource, entity, project, docker_image, config, queue, run_async, resource_args, cuda, build, repository, project_queue) → function launch(uri, job, entry_point, git_version, args_list, name, resource, entity, project, docker_image, config, queue, run_async, resource_args, build, repository, project_queue) - added:
function importer() - added:
function mlflow(mlflow_tracking_uri, target_entity, target_project)
- removed:
class WaitTimeoutError(Error) - removed:
method Error.encode(encoding) - added:
class AuthenticationError(CommError)
- added:
class ProtobufErrorHandler - added:
static method ProtobufErrorHandler.from_exception(exc: Error) -> pb.ErrorInfo - added:
static method ProtobufErrorHandler.to_exception(error: pb.ErrorInfo) -> Optional[Error] - added:
variable from_exception_map - added:
variable to_exception_map
- added:
field RequestStoreManifestFiles.save_fn_async: internal_artifacts.SaveFnAsync
- removed:
field RequestPrepare.response_queue: queue.Queue[ResponsePrepare] - removed:
method StepPrepare.prepare(file_spec: CreateArtifactFileSpecInput) -> ResponsePrepare - changed:
method StepPrepare.prepare_async(file_spec: CreateArtifactFileSpecInput) -> queue.Queue[ResponsePrepare] → method StepPrepare.prepare_async(file_spec: CreateArtifactFileSpecInput) -> asyncio.Future[ResponsePrepare] - added:
field RequestPrepare.response_channel: Union[queue.Queue[ResponsePrepare], Tuple[asyncio.AbstractEventLoop, asyncio.Future[ResponsePrepare]]] - added:
method StepPrepare.prepare_sync(file_spec: CreateArtifactFileSpecInput) -> queue.Queue[ResponsePrepare]
- changed:
constructor StepUpload(api: internal_api.Api, stats: stats.Stats, event_queue: queue.Queue[Event], max_jobs: int, file_stream: file_stream.FileStreamApi, silent: bool=…) -> None → constructor StepUpload(api: internal_api.Api, stats: stats.Stats, event_queue: queue.Queue[Event], max_threads: int, file_stream: file_stream.FileStreamApi, settings: Optional[SettingsStatic]=…) -> None - added:
class AsyncExecutor - added:
constructor AsyncExecutor(pool: concurrent.futures.ThreadPoolExecutor, concurrency_limit: Optional[int]) -> None - added:
field RequestUpload.save_fn_async: Optional[SaveFnAsync] - added:
method AsyncExecutor.start() -> None - added:
method AsyncExecutor.stop() -> None - added:
method AsyncExecutor.submit(coro: Awaitable[None]) -> None - added:
variable SaveFnAsync
- changed:
field EventJobDone.job: UploadJob → field EventJobDone.job: step_upload.RequestUpload - added:
async method UploadJobAsync.run() -> None - added:
class UploadJobAsync - added:
constructor UploadJobAsync(stats: stats.Stats, api: internal_api.Api, file_stream: file_stream.FileStreamApi, silent: bool, request: step_upload.RequestUpload, save_fn_async: step_upload.SaveFnAsync) -> None
- removed:
method Backend.server_connect() -> None
- removed:
class Artifact - removed:
class ArtifactFinalizedError(ArtifactStatusError) - removed:
class ArtifactManifest - removed:
class ArtifactManifestEntry - removed:
class ArtifactNotLoggedError(ArtifactStatusError) - removed:
class ArtifactStatusError(AttributeError) - removed:
class ArtifactsCache - removed:
class Opener(Protocol) - removed:
class StorageHandler - removed:
class StorageLayout - removed:
class StoragePolicy - removed:
constructor ArtifactFinalizedError(artifact: Optional[Artifact]=…, attr: Optional[str]=…) - removed:
constructor ArtifactManifest(storage_policy: wandb_artifacts.WandbStoragePolicy, entries: Optional[Mapping[str, ArtifactManifestEntry]]=…) -> None - removed:
constructor ArtifactNotLoggedError(artifact: Optional[Artifact]=…, attr: Optional[str]=…) - removed:
constructor ArtifactStatusError(artifact: Optional[Artifact]=…, attr: Optional[str]=…, msg: str=…) - removed:
constructor ArtifactsCache(cache_dir: StrPath) -> None - removed:
field ArtifactManifest.entries: Dict[str, ArtifactManifestEntry] - removed:
field ArtifactManifestEntry.birth_artifact_id: Optional[str] - removed:
field ArtifactManifestEntry.digest: Union[B64MD5, URIStr, FilePathStr, ETag] - removed:
field ArtifactManifestEntry.extra: Dict - removed:
field ArtifactManifestEntry.local_path: Optional[str] - removed:
field ArtifactManifestEntry.path: LogicalFilePathStr - removed:
field ArtifactManifestEntry.ref: Optional[Union[FilePathStr, URIStr]] - removed:
field ArtifactManifestEntry.size: Optional[int] - removed:
field StorageLayout.V1 - removed:
field StorageLayout.V2 - removed:
function get_artifacts_cache() -> ArtifactsCache - removed:
function get_new_staging_file() -> IO - removed:
function get_staging_dir() -> FilePathStr - removed:
method Artifact.add(obj: WBValue, name: str) -> ArtifactManifestEntry - removed:
method Artifact.add_dir(local_path: str, name: Optional[str]=…) -> None - removed:
method Artifact.add_file(local_path: str, name: Optional[str]=…, is_tmp: Optional[bool]=…) -> ArtifactManifestEntry - removed:
method Artifact.add_reference(uri: Union[ArtifactManifestEntry, str], name: Optional[str]=…, checksum: bool=…, max_objects: Optional[int]=…) -> Sequence[ArtifactManifestEntry] - removed:
method Artifact.checkout(root: Optional[str]=…) -> str - removed:
method Artifact.delete() -> None - removed:
method Artifact.download(root: Optional[str]=…, recursive: bool=…) -> FilePathStr - removed:
method Artifact.get(name: str) -> WBValue - removed:
method Artifact.get_path(name: str) -> ArtifactManifestEntry - removed:
method Artifact.link(target_path: str, aliases: Optional[List[str]]=…) -> None - removed:
method Artifact.logged_by() -> wandb.apis.public.Run - removed:
method Artifact.new_file(name: str, mode: str=…, encoding: Optional[str]=…) -> ContextManager[IO] - removed:
method Artifact.save() -> None - removed:
method Artifact.used_by() -> List[wandb.apis.public.Run] - removed:
method Artifact.verify(root: Optional[str]=…) -> bool - removed:
method Artifact.wait() -> Artifact - removed:
method ArtifactManifest.add_entry(entry: ArtifactManifestEntry) -> None - removed:
method ArtifactManifest.digest() -> HexMD5 - removed:
method ArtifactManifest.get_entries_in_directory(directory: str) -> List[ArtifactManifestEntry] - removed:
method ArtifactManifest.get_entry_by_path(path: str) -> Optional[ArtifactManifestEntry] - removed:
method ArtifactManifest.to_manifest_json() -> Dict - removed:
method ArtifactManifestEntry.download(root: Optional[str]=…) -> FilePathStr - removed:
method ArtifactManifestEntry.parent_artifact() -> Artifact - removed:
method ArtifactManifestEntry.ref_target() -> str - removed:
method ArtifactManifestEntry.ref_url() -> str - removed:
method ArtifactsCache.check_etag_obj_path(url: URIStr, etag: ETag, size: int) -> Tuple[FilePathStr, bool, Opener] - removed:
method ArtifactsCache.check_md5_obj_path(b64_md5: B64MD5, size: int) -> Tuple[FilePathStr, bool, Opener] - removed:
method ArtifactsCache.cleanup(target_size: int) -> int - removed:
method ArtifactsCache.get_artifact(artifact_id: str) -> Optional[Artifact] - removed:
method ArtifactsCache.get_client_artifact(client_id: str) -> Optional[wandb_artifacts.Artifact] - removed:
method ArtifactsCache.store_artifact(artifact: Artifact) -> None - removed:
method ArtifactsCache.store_client_artifact(artifact: wandb_artifacts.Artifact) -> None - removed:
method StorageHandler.load_path(manifest_entry: ArtifactManifestEntry, local: bool=…) -> Union[URIStr, FilePathStr] - removed:
method StorageHandler.store_path(artifact: Artifact, path: Union[URIStr, FilePathStr], name: Optional[str]=…, checksum: bool=…, max_objects: Optional[int]=…) -> Sequence[ArtifactManifestEntry] - removed:
method StoragePolicy.config() -> Dict - removed:
method StoragePolicy.load_file(artifact: Artifact, manifest_entry: ArtifactManifestEntry) -> str - removed:
method StoragePolicy.load_reference(manifest_entry: ArtifactManifestEntry, local: bool=…) -> str - removed:
method StoragePolicy.store_file(artifact_id: str, artifact_manifest_id: str, entry: ArtifactManifestEntry, preparer: StepPrepare, progress_callback: Optional[progress.ProgressFn]=…) -> bool - removed:
method StoragePolicy.store_reference(artifact: Artifact, path: Union[URIStr, FilePathStr], name: Optional[str]=…, checksum: bool=…, max_objects: Optional[int]=…) -> Sequence[ArtifactManifestEntry] - removed:
property Artifact.aliases -> List[str] - removed:
property Artifact.commit_hash -> str - removed:
property Artifact.description -> Optional[str] - removed:
property Artifact.digest -> str - removed:
property Artifact.entity -> str - removed:
property Artifact.id -> Optional[str] - removed:
property Artifact.manifest -> ArtifactManifest - removed:
property Artifact.metadata -> dict - removed:
property Artifact.name -> str - removed:
property Artifact.project -> str - removed:
property Artifact.size -> int - removed:
property Artifact.source_version -> Optional[str] - removed:
property Artifact.state -> str - removed:
property Artifact.type -> str - removed:
property Artifact.version -> str - removed:
property StorageHandler.scheme -> str - removed:
static method ArtifactManifest.from_manifest_json(manifest_json: Dict) -> ArtifactManifest - removed:
static method ArtifactManifest.version() -> int - removed:
static method StoragePolicy.from_config(config: Dict) -> StoragePolicy - removed:
static method StoragePolicy.lookup_by_name(name: str) -> Optional[Type[StoragePolicy]] - removed:
static method StoragePolicy.name() -> str - added:
export Artifact - added:
export ArtifactFinalizedError - added:
export ArtifactManifest - added:
export ArtifactManifestEntry - added:
export ArtifactNotLoggedError - added:
export ArtifactStatusError - added:
export ArtifactsCache - added:
export StorageHandler - added:
export StorageLayout - added:
export StoragePolicy - added:
export get_artifacts_cache
- added:
class Artifact - added:
class ArtifactFinalizedError(ArtifactStatusError) - added:
class ArtifactNotLoggedError(ArtifactStatusError) - added:
class ArtifactStatusError(AttributeError) - added:
constructor ArtifactFinalizedError(artifact: Optional[Artifact]=…, attr: Optional[str]=…) - added:
constructor ArtifactNotLoggedError(artifact: Optional[Artifact]=…, attr: Optional[str]=…) - added:
constructor ArtifactStatusError(artifact: Optional[Artifact]=…, attr: Optional[str]=…, msg: str=…) - added:
method Artifact.add(obj: WBValue, name: str) -> ArtifactManifestEntry - added:
method Artifact.add_dir(local_path: str, name: Optional[str]=…) -> None - added:
method Artifact.add_file(local_path: str, name: Optional[str]=…, is_tmp: Optional[bool]=…) -> ArtifactManifestEntry - added:
method Artifact.add_reference(uri: Union[ArtifactManifestEntry, str], name: Optional[str]=…, checksum: bool=…, max_objects: Optional[int]=…) -> Sequence[ArtifactManifestEntry] - added:
method Artifact.checkout(root: Optional[str]=…) -> str - added:
method Artifact.delete() -> None - added:
method Artifact.download(root: Optional[str]=…, recursive: bool=…) -> FilePathStr - added:
method Artifact.get(name: str) -> WBValue - added:
method Artifact.get_path(name: str) -> ArtifactManifestEntry - added:
method Artifact.link(target_path: str, aliases: Optional[List[str]]=…) -> None - added:
method Artifact.logged_by() -> wandb.apis.public.Run - added:
method Artifact.new_file(name: str, mode: str=…, encoding: Optional[str]=…) -> ContextManager[IO] - added:
method Artifact.save() -> None - added:
method Artifact.used_by() -> List[wandb.apis.public.Run] - added:
method Artifact.verify(root: Optional[str]=…) -> bool - added:
method Artifact.wait() -> Artifact - added:
property Artifact.aliases -> List[str] - added:
property Artifact.commit_hash -> str - added:
property Artifact.description -> Optional[str] - added:
property Artifact.digest -> str - added:
property Artifact.entity -> str - added:
property Artifact.id -> Optional[str] - added:
property Artifact.manifest -> ArtifactManifest - added:
property Artifact.metadata -> dict - added:
property Artifact.name -> str - added:
property Artifact.project -> str - added:
property Artifact.size -> int - added:
property Artifact.source_version -> Optional[str] - added:
property Artifact.state -> str - added:
property Artifact.type -> str - added:
property Artifact.version -> str
- added:
class ArtifactsCache - added:
class Opener(Protocol) - added:
constructor ArtifactsCache(cache_dir: StrPath) -> None - added:
function get_artifacts_cache() -> ArtifactsCache - added:
method ArtifactsCache.check_etag_obj_path(url: URIStr, etag: ETag, size: int) -> Tuple[FilePathStr, bool, Opener] - added:
method ArtifactsCache.check_md5_obj_path(b64_md5: B64MD5, size: int) -> Tuple[FilePathStr, bool, Opener] - added:
method ArtifactsCache.cleanup(target_size: int) -> int - added:
method ArtifactsCache.get_artifact(artifact_id: str) -> Optional[Artifact] - added:
method ArtifactsCache.get_client_artifact(client_id: str) -> Optional[wandb_artifacts.Artifact] - added:
method ArtifactsCache.store_artifact(artifact: Artifact) -> None - added:
method ArtifactsCache.store_client_artifact(artifact: wandb_artifacts.Artifact) -> None
- added:
class ArtifactManifest - added:
class ArtifactManifestEntry - added:
constructor ArtifactManifest(storage_policy: wandb_artifacts.WandbStoragePolicy, entries: Optional[Mapping[str, ArtifactManifestEntry]]=…) -> None - added:
field ArtifactManifest.entries: Dict[str, ArtifactManifestEntry] - added:
field ArtifactManifestEntry.birth_artifact_id: Optional[str] - added:
field ArtifactManifestEntry.digest: Union[B64MD5, URIStr, FilePathStr, ETag] - added:
field ArtifactManifestEntry.extra: Dict - added:
field ArtifactManifestEntry.local_path: Optional[str] - added:
field ArtifactManifestEntry.path: LogicalFilePathStr - added:
field ArtifactManifestEntry.ref: Optional[Union[FilePathStr, URIStr]] - added:
field ArtifactManifestEntry.size: Optional[int] - added:
method ArtifactManifest.add_entry(entry: ArtifactManifestEntry) -> None - added:
method ArtifactManifest.digest() -> HexMD5 - added:
method ArtifactManifest.get_entries_in_directory(directory: str) -> List[ArtifactManifestEntry] - added:
method ArtifactManifest.get_entry_by_path(path: str) -> Optional[ArtifactManifestEntry] - added:
method ArtifactManifest.to_manifest_json() -> Dict - added:
method ArtifactManifestEntry.download(root: Optional[str]=…) -> FilePathStr - added:
method ArtifactManifestEntry.parent_artifact() -> Artifact - added:
method ArtifactManifestEntry.ref_target() -> str - added:
method ArtifactManifestEntry.ref_url() -> str - added:
static method ArtifactManifest.from_manifest_json(manifest_json: Dict) -> ArtifactManifest - added:
static method ArtifactManifest.version() -> int
- added:
async method StoragePolicy.store_file_async(artifact_id: str, artifact_manifest_id: str, entry: ArtifactManifestEntry, preparer: StepPrepare, progress_callback: Optional[ProgressFn]=…) -> bool - added:
class StorageHandler - added:
class StorageLayout - added:
class StoragePolicy - added:
field StorageLayout.V1 - added:
field StorageLayout.V2 - added:
method StorageHandler.load_path(manifest_entry: ArtifactManifestEntry, local: bool=…) -> Union[URIStr, FilePathStr] - added:
method StorageHandler.store_path(artifact: Artifact, path: Union[URIStr, FilePathStr], name: Optional[str]=…, checksum: bool=…, max_objects: Optional[int]=…) -> Sequence[ArtifactManifestEntry] - added:
method StoragePolicy.config() -> Dict - added:
method StoragePolicy.load_file(artifact: Artifact, manifest_entry: ArtifactManifestEntry) -> str - added:
method StoragePolicy.load_reference(manifest_entry: ArtifactManifestEntry, local: bool=…) -> str - added:
method StoragePolicy.store_file_sync(artifact_id: str, artifact_manifest_id: str, entry: ArtifactManifestEntry, preparer: StepPrepare, progress_callback: Optional[ProgressFn]=…) -> bool - added:
method StoragePolicy.store_reference(artifact: Artifact, path: Union[URIStr, FilePathStr], name: Optional[str]=…, checksum: bool=…, max_objects: Optional[int]=…) -> Sequence[ArtifactManifestEntry] - added:
property StorageHandler.scheme -> str - added:
static method StoragePolicy.from_config(config: Dict) -> StoragePolicy - added:
static method StoragePolicy.lookup_by_name(name: str) -> Optional[Type[StoragePolicy]] - added:
static method StoragePolicy.name() -> str
- added:
class SaveFnAsync(Protocol) - added:
function get_staging_dir() -> FilePathStr
- changed:
constructor FilePusher(api: internal_api.Api, file_stream: file_stream.FileStreamApi, silent: Optional[bool]=…) -> None → constructor FilePusher(api: internal_api.Api, file_stream: file_stream.FileStreamApi, settings: Optional[SettingsStatic]=…) -> None - changed:
method FilePusher.store_manifest_files(manifest: artifacts.ArtifactManifest, artifact_id: str, save_fn: internal_artifacts.SaveFn) -> None → method FilePusher.store_manifest_files(manifest: artifacts.ArtifactManifest, artifact_id: str, save_fn: internal_artifacts.SaveFn, save_fn_async: internal_artifacts.SaveFnAsync) -> None
- removed:
method Api.display_gorilla_error_if_found(res: requests.Response) -> None - changed:
method Api.server_info_introspection() -> Tuple[List[str], List[str]] → method Api.server_info_introspection() -> Tuple[List[str], List[str], List[str]] - added:
async method Api.upload_file_async(url: str, file: IO[bytes], callback: Optional[ProgressFn]=…, extra_headers: Optional[Dict[str, str]]=…) -> None - added:
async method Api.upload_file_retry_async(url: str, file: IO[bytes], callback: Optional[ProgressFn]=…, extra_headers: Optional[Dict[str, str]]=…, num_retries: int=…) -> None - added:
function check_httpx_exc_retriable(exc: Exception) -> bool - added:
method Api.entity_is_team(entity: str) -> bool - added:
method Api.fail_run_queue_item(run_queue_item_id: str) -> bool - added:
method Api.fail_run_queue_item_introspection() -> bool - added:
variable httpx
- added:
class AsyncProgress - added:
constructor AsyncProgress(progress: Progress) -> None - added:
method AsyncProgress.rewind() -> None
- changed:
constructor CPU(interface: Interface, settings: SettingsStatic, shutdown_event: mp.synchronize.Event) -> None → constructor CPU(interface: Interface, settings: SettingsStatic, shutdown_event: threading.Event) -> None
- changed:
constructor Disk(interface: Interface, settings: SettingsStatic, shutdown_event: mp.synchronize.Event) -> None → constructor Disk(interface: Interface, settings: SettingsStatic, shutdown_event: threading.Event) -> None
- changed:
constructor GPU(interface: Interface, settings: SettingsStatic, shutdown_event: mp.synchronize.Event) -> None → constructor GPU(interface: Interface, settings: SettingsStatic, shutdown_event: threading.Event) -> None
- changed:
constructor GPUApple(interface: Interface, settings: SettingsStatic, shutdown_event: mp.synchronize.Event) -> None → constructor GPUApple(interface: Interface, settings: SettingsStatic, shutdown_event: threading.Event) -> None
- changed:
constructor MetricsMonitor(asset_name: str, metrics: List[Metric], interface: Interface, settings: SettingsStatic, shutdown_event: synchronize.Event) -> None → constructor MetricsMonitor(asset_name: str, metrics: List[Metric], interface: Interface, settings: SettingsStatic, shutdown_event: threading.Event) -> None
- changed:
constructor IPU(interface: Interface, settings: SettingsStatic, shutdown_event: mp.synchronize.Event) -> None → constructor IPU(interface: Interface, settings: SettingsStatic, shutdown_event: threading.Event) -> None
- changed:
constructor Memory(interface: Interface, settings: SettingsStatic, shutdown_event: mp.synchronize.Event) -> None → constructor Memory(interface: Interface, settings: SettingsStatic, shutdown_event: threading.Event) -> None
- changed:
constructor Network(interface: Interface, settings: SettingsStatic, shutdown_event: mp.synchronize.Event) -> None → constructor Network(interface: Interface, settings: SettingsStatic, shutdown_event: threading.Event) -> None
- changed:
constructor OpenMetrics(interface: Interface, settings: SettingsStatic, shutdown_event: mp.synchronize.Event, name: str, url: str) -> None → constructor OpenMetrics(interface: Interface, settings: SettingsStatic, shutdown_event: threading.Event, name: str, url: str) -> None
- changed:
constructor TPU(interface: Interface, settings: SettingsStatic, shutdown_event: mp.synchronize.Event) -> None → constructor TPU(interface: Interface, settings: SettingsStatic, shutdown_event: threading.Event) -> None
- changed:
constructor Trainium(interface: Interface, settings: SettingsStatic, shutdown_event: mp.synchronize.Event) -> None → constructor Trainium(interface: Interface, settings: SettingsStatic, shutdown_event: threading.Event) -> None
- added:
field JobAndRunStatus.project: Optional[str] - added:
field JobAndRunStatus.run_id: Optional[str] - added:
field JobAndRunStatus.run_queue_item_id: str - added:
method JobAndRunStatus.update_run_info(launch_project: LaunchProject) -> None - added:
method LaunchAgent.fail_run_queue_item(run_queue_item_id: str) -> None
- removed:
function construct_gcp_image_uri(launch_project: LaunchProject, gcp_repo: str, gcp_project: str, gcp_registry: str) -> str - removed:
function docker_image_exists(docker_image: str, should_raise: bool=…) -> bool - removed:
function docker_image_inspect(docker_image: str) -> Dict[str, Any] - removed:
function pull_docker_image(docker_image: str) -> None - added:
function image_tag_from_dockerfile_and_source(launch_project: LaunchProject, dockerfile_contents: str) -> str
- added:
method AbstractRegistry.check_image_exists(image_uri: str) -> bool
- added:
method ElasticContainerRegistry.check_image_exists(image_uri: str) -> bool
- added:
method GoogleArtifactRegistry.check_image_exists(image_uri: str) -> bool
- added:
method LocalRegistry.check_image_exists(image_uri: str) -> bool
- removed:
method AbstractRunner.ack_run_queue_item(launch_project: LaunchProject) -> bool
- added:
field SchedulerState.CANCELLED
- changed:
function construct_launch_spec(uri: Optional[str], job: Optional[str], api: Api, name: Optional[str], project: Optional[str], entity: Optional[str], docker_image: Optional[str], resource: Optional[str], entry_point: Optional[List[str]], version: Optional[str], parameters: Optional[Dict[str, Any]], resource_args: Optional[Dict[str, Any]], launch_config: Optional[Dict[str, Any]], cuda: Optional[boo… → function construct_launch_spec(uri: Optional[str], job: Optional[str], api: Api, name: Optional[str], project: Optional[str], entity: Optional[str], docker_image: Optional[str], resource: Optional[str], entry_point: Optional[List[str]], version: Optional[str], parameters: Optional[Dict[str, Any]], resource_args: Optional[Dict[str, Any]], launch_config: Optional[Dict[str, Any]], run_id: Optional[s… - added:
class LaunchDockerError(Error) - added:
function docker_image_exists(docker_image: str, should_raise: bool=…) -> bool - added:
function pull_docker_image(docker_image: str) -> None - added:
function warn_failed_packages_from_build_logs(log: str, image_uri: str) -> None - added:
variable FAILED_PACKAGES_REGEX
- added:
export lazyloader
- added:
class GraphQLSession(HTTPTransport) - added:
constructor GraphQLSession(url: str, auth: Optional[Union[Tuple[str, str], Callable]]=…, use_json: bool=…, timeout: Optional[Union[int, float]]=…, **kwargs: Any) -> None - added:
method GraphQLSession.execute(document: ast.Node, variable_values: Optional[Dict]=…, timeout: Optional[Union[int, float]]=…) -> ExecutionResult
- removed:
method WandbStoragePolicy.store_file(artifact_id: str, artifact_manifest_id: str, entry: ArtifactManifestEntry, preparer: StepPrepare, progress_callback: Optional[progress.ProgressFn]=…) -> bool - added:
async method WandbStoragePolicy.store_file_async(artifact_id: str, artifact_manifest_id: str, entry: ArtifactManifestEntry, preparer: StepPrepare, progress_callback: Optional[progress.ProgressFn]=…) -> bool - added:
method WandbStoragePolicy.store_file_sync(artifact_id: str, artifact_manifest_id: str, entry: ArtifactManifestEntry, preparer: StepPrepare, progress_callback: Optional[progress.ProgressFn]=…) -> bool
- changed:
method Run.log_artifact(artifact_or_path: Union[wandb_artifacts.Artifact, str], name: Optional[str]=…, type: Optional[str]=…, aliases: Optional[List[str]]=…) -> wandb_artifacts.Artifact → method Run.log_artifact(artifact_or_path: Union[wandb_artifacts.Artifact, StrPath], name: Optional[str]=…, type: Optional[str]=…, aliases: Optional[List[str]]=…) -> wandb_artifacts.Artifact - added:
class WaitTimeoutError(errors.Error)
- removed:
function sentry_exc(exc: Union[str, BaseException, Tuple[Optional[Type[BaseException]], Optional[BaseException], Optional[TracebackType]], None], delay: bool=…) -> None - removed:
function sentry_message(message: str) -> None - removed:
function sentry_reraise(exc: Any, delay: bool=…) -> None - removed:
function sentry_set_scope(settings_dict: Optional[Union[wandb.sdk.wandb_settings.Settings, wandb.sdk.internal.settings_static.SettingsStatic]]=…, process_context: Optional[str]=…) -> None - removed:
variable sentry_client - removed:
variable sentry_client: Optional[sentry_sdk.client.Client] - removed:
variable sentry_default_dsn - removed:
variable sentry_dsn - removed:
variable sentry_hub - removed:
variable sentry_hub: Optional[sentry_sdk.hub.Hub] - changed:
function rand_alphanumeric(length: int=…, rand: Optional[random.Random]=…) -> str → function rand_alphanumeric(length: int=…, rand: Optional[Union[ModuleType, random.Random]]=…) -> str