a d(@sdZddlZddlZddlmZddlmZmZmZm Z ddl m Z ddl Z ddlmZmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlm Z m!Z!e"e#Z$erddl%m&Z&m'Z'esesddgZ(GdddeeZdS)z' TensorBoard Logger ------------------ N) Namespace)AnyDictOptionalUnion)Tensor)_TENSORBOARD_AVAILABLE_TENSORBOARDX_AVAILABLE)TensorBoardLogger)_convert_params)_PATH)ModelCheckpoint)save_hparams_to_yaml)Logger)_OMEGACONF_AVAILABLE)rank_zero_onlyrank_zero_warn) Container OmegaConfr zTensorBoardLogger.*c s(eZdZdZdZd#eeeeee efe e eeee dfd d Z e ed fd d Ze ed ddZe ed ddZed$eeee fefeeee fddfdd Zed%deeddddZedd fdd Zeeddfdd Zedddd Ze d d!d"ZZS)&r a Log to local file system in `TensorBoard `_ format. Implemented using :class:`~tensorboardX.SummaryWriter`. Logs are saved to ``os.path.join(save_dir, name, version)``. This is the default logger in Lightning, it comes preinstalled. Example: .. testcode:: from pytorch_lightning import Trainer from pytorch_lightning.loggers import TensorBoardLogger logger = TensorBoardLogger("tb_logs", name="my_model") trainer = Trainer(logger=logger) Args: save_dir: Save directory name: Experiment name. Defaults to ``'default'``. If it is the empty string then no per-experiment subdirectory is used. version: Experiment version. If version is not specified the logger inspects the save directory for existing versions, then automatically assigns the next available version. If it is a string then it is used as the run-specific subdirectory name, otherwise ``'version_${version}'`` is used. log_graph: Adds the computational graph to tensorboard. This requires that the user has defined the `self.example_input_array` attribute in their model. default_hp_metric: Enables a placeholder metric with key `hp_metric` when `log_hyperparams` is called without a metric (otherwise calls to log_hyperparams without a metric are ignored). prefix: A string to put at the beginning of metric keys. sub_dir: Sub-directory to group TensorBoard logs. If a sub_dir argument is passed then logs are saved in ``/save_dir/name/version/sub_dir/``. Defaults to ``None`` in which logs are saved in ``/save_dir/name/version/``. \**kwargs: Additional arguments used by :class:`tensorboardX.SummaryWriter` can be passed as keyword arguments in this logger. To automatically flush to disk, `max_queue` sets the size of the queue for pending logs before flushing. `flush_secs` determines how many seconds elapses before flushing. Example: >>> import shutil, tempfile >>> tmp = tempfile.mkdtemp() >>> tbl = TensorBoardLogger(tmp) >>> tbl.log_hyperparams({"epochs": 5, "optimizer": "Adam"}) >>> tbl.log_metrics({"acc": 0.75}) >>> tbl.log_metrics({"acc": 0.9}) >>> tbl.finalize("success") >>> shutil.rmtree(tmp) z hparams.yamllightning_logsNFT)save_dirnameversion log_graphdefault_hp_metricprefixsub_dirkwargsc sDtjf||||||d||r0ts0td|o6t|_i|_dS)N)root_dirrrrrrzOYou set `TensorBoardLogger(log_graph=True)` but `tensorboard` is not available.)super__init__rr _log_graphhparams) selfrrrrrrrr __class__n/var/www/html/stable-diffusion-webui/venv/lib/python3.9/site-packages/pytorch_lightning/loggers/tensorboard.pyr!cs   zTensorBoardLogger.__init__)returncstjtj|jS)zParent directory for all tensorboard checkpoint subdirectories. If the experiment name parameter is an empty string, no experiment subdirectory is used and the checkpoint will be saved in "save_dir/version" )ospathjoinr rrr$r%r'r(r|szTensorBoardLogger.root_dircCsft|jtr|jn d|j}tj|j|}t|jtrJtj||j}tj|}tj |}|S)zThe directory for this run's tensorboard checkpoint. By default, it is named ``'version_${self.version}'`` but it can be overridden by passing a string value for the constructor's version parameter instead of ``None`` or an int. version_) isinstancerstrr*r+r,rr expandvars expanduser)r$rlog_dirr'r'r(r3s   zTensorBoardLogger.log_dircCs|jS)zGets the save directory where the TensorBoard experiments are saved. Returns: The local path to the save directory where the TensorBoard experiments are saved. )Z _root_dirr-r'r'r(rszTensorBoardLogger.save_dir)paramsmetricsr)csDt|}tr(t|tr(t|j||_n |j|tj ||dS)aRecord hyperparameters. TensorBoard logs with and without saved hyperparameters are incompatible, the hyperparameters are then not displayed in the TensorBoard. Please delete or move the previously saved logs to display the new ones with hyperparameters. Args: params: a dictionary-like container with the hyperparameters metrics: Dictionary with metric names as keys and measured quantities as values )r4r5) r rr/rrmerger#updater log_hyperparams)r$r4r5r%r'r(r8s  z!TensorBoardLogger.log_hyperparamszpl.LightningModule)model input_arrayr)cCs|js dS|dur|jn|}|dur.tdnrt|ttfsRtdt|dnN||}||}t j j |j ||Wdn1s0YdS)NzCould not log computational graph to TensorBoard: The `model.example_input_array` attribute is not set or `input_array` was not given.zlCould not log computational graph to TensorBoard: The `input_array` or `model.example_input_array` has type z which can't be traced by TensorBoard. Make the input array a tuple representing the positional arguments to the model's `forward()` implementation.)r"Zexample_input_arrayrr/rtupletypeZ_on_before_batch_transferZ_apply_batch_transfer_handlerplcoremoduleZ_jit_is_scriptingZ experimentZ add_graph)r$r9r:r'r'r(rs"  zTensorBoardLogger.log_graphcsHt|j}tj||j}|j|rD|j |sDt ||j dS)N) r saver3r*r+r,NAME_HPARAMS_FILE_fsisdirisfilerr#)r$Zdir_pathZ hparams_filer%r'r(r@s  zTensorBoardLogger.save)statusr)cs t||dkr|dS)Nsuccess)r finalizer@)r$rEr%r'r(rGs zTensorBoardLogger.finalize)checkpoint_callbackr)cCsdS)zCalled after model checkpoint callback saves a new checkpoint. Args: checkpoint_callback: the model checkpoint callback instance Nr')r$rHr'r'r(after_save_checkpointsz'TensorBoardLogger.after_save_checkpointcCs|j}z|j|}Wn ty6td|YdS0g}|D]R}|d}tj|}|j |r@| dr@| dd dd}| t|q@t|dkrdSt|dS) NzMissing logger folder: %srrr._/r)rrBlistdirOSErrorlogwarningr*r+basenamerC startswithsplitreplaceappendintlenmax)r$rZ listdir_infoZexisting_versionslistingdZbnZdir_verr'r'r(_get_next_versions     z#TensorBoardLogger._get_next_version)rNFTrN)N)N)__name__ __module__ __qualname____doc__rAr rr0rrVboolrr!propertyrr3rrrrr8rrr@rGr rIr[ __classcell__r'r'r%r(r /sL1  ))r_loggingr*argparsertypingrrrrZtorchrZpytorch_lightningr=Z$lightning_fabric.loggers.tensorboardrr r ZFabricTensorBoardLoggerZ!lightning_fabric.utilities.loggerr Z lightning_fabric.utilities.typesr Zpytorch_lightning.callbacksr Zpytorch_lightning.core.savingrZ pytorch_lightning.loggers.loggerrZ#pytorch_lightning.utilities.importsrZ%pytorch_lightning.utilities.rank_zerorr getLoggerr\rOZ omegaconfrrZ__doctest_skip__r'r'r'r(s*