o Õ2úhã@sXdZddlZddlmZmZddlmZddlmZGdd„dƒZ Gdd „d ej ƒZ dS) z(Experimental API for checkpoint adapter.éN)ÚListÚOptional)Útensor)Úbasec@s^eZdZdZdefdd„Zdeejdeedejfdd„Z de eeeeffd d „Z d S) ÚReshardCallbackzÈAPI to reshard a checkpoint value during restore. When a ReshardCallback is attached to a CheckpointPosition, the restored value of the checkpoint position is resharded based on this callback. ÚreturncCódS)zšReturns the local name of the object being restored. Override this method when the local name of object is different than in the checkpoint. N©)Úselfr r új/var/www/html/chatgem/venv/lib/python3.10/site-packages/tensorflow/python/checkpoint/checkpoint_adapter.pyÚ object_nameszReshardCallback.object_nameÚcheckpoint_valuesÚshape_and_slice_speccCs~t|ƒdkr tdƒ‚|dS)azReshards the checkpoint values as read from the checkpoint file. Override this to reshard/modify the restored values Args: checkpoint_values: The values returned by the restore op, as read from file. shape_and_slice_spec: The shape and slice spec required by the caller. Returns: List of restored Tensor values after being resharded. éz2Default reshard expects a single checkpoint value.r)ÚlenÚ ValueError)r r rr r r Úreshard&s zReshardCallback.reshardcCs |g|gfS)a:Updates the specs to restore op. Override this method if the arguments to restore op need to be updated as per the resharding required. Args: checkpoint_key: The checkpoint key as requested by the caller shape_and_slice_spec: The shape and slice spec as requested by caller Returns: Tuple of list of checkpoint_keys and specs that the restore op should fetch as per the resharding requirement. The length of checkpoint keys returned by this method will match the length of checkpoint_values that are input to `reshard`. r )r Úcheckpoint_keyrr r r Úupdate_restore_inputs<s z%ReshardCallback.update_restore_inputsN) Ú__name__Ú __module__Ú __qualname__Ú__doc__Ústrr rrÚTensorrÚtuplerr r r r rsþý üþrc@s|eZdZdZeejdefdd„ƒƒZejde j de fdd„ƒZ ejd ede efd d „ƒZd edeee effd d „ZdS)ÚAbstractCheckpointAdapterz Abstract API for checkpoint adapter. This is an experimental API that specifies how checkpoint restore should be adapted for specific trackable objects. ÚpathcCr)zdCreate factory to create an Adapter from checkpoint. Args: path: Path to checkpoint. Nr )Úclsrr r r Úcreate_from_checkpointWóz0AbstractCheckpointAdapter.create_from_checkpointÚ trackablercCr)aReturns whether the adapter is applicable to trackable for resharding. Args: trackable: A Trackable object that is being restored. Returns: A Boolean indicating if the checkpoint value for this Trackable should be resharded. Nr )r r!r r r Ú is_applicable`r z'AbstractCheckpointAdapter.is_applicableÚnamecCr)z;Returns the reshard callback for the trackable with `name`.Nr )r r#r r r Úget_reshard_callbacklr z.AbstractCheckpointAdapter.get_reshard_callbackcCs6| |¡}|dur |dfS| ¡r| ¡|fS||fS)z>Returns the updated name and ReshardCallback applicable to it.N)r$r )r r#Úcallbackr r r Ú maybe_reshardps  z'AbstractCheckpointAdapter.maybe_reshardN)rrrrÚ classmethodÚabcÚabstractmethodrrrÚ TrackableÚboolr"rrr$rr&r r r r rPs "r) rr(ÚtypingrrÚtensorflow.python.frameworkrÚtensorflow.python.trackablerrÚABCrr r r r Ús  9