code: def get(self) -> Any:
      if _is_flow_context():
          raise RuntimeError(
              "`Payload.get()` can only be called from within the `run()` method of LightningWork."
          )
  
      if self._request_queue is None or self._response_queue is None:
          raise RuntimeError(
              f"Trying to get the file {self}, but the payload is not attached to a LightningApp."
              f" Are you trying to get the file from within `__init__`?"
          )
      if self._origin is None:
          raise RuntimeError(
              f"Trying to get the file {self}, but the payload is not attached to a LightningWork. Set it as an"
              f" attribute to a LightningWork or pass it to the `run()` method."
          )
  
      # 1. Send message to orchestrator through queue with details of the transfer
      # the source is the name of the work that owns the file that we request
      # the destination is determined by the queue, since each work has a dedicated send and recv queue
      request = _GetRequest(
          source=self.origin_name,
          name=self._name,
          path=str(self._path),
          hash=self.hash,
      )
      self._request_queue.put(request)
  
      # 2. Wait for the transfer to finish
      response: _GetResponse = self._response_queue.get()  # blocking
      self._validate_get_response(response)
  
      fs = _filesystem()
  
      # 3. Wait until the file appears in shared storage
      while (
          not fs.exists(response.path)
          or fs.info(response.path)["size"] != response.size
      ):
          sleep(REMOTE_STORAGE_WAIT)
  
      # 4. Copy the file from the shared storage to the destination on the local filesystem
      local_path = self._path
      _logger.debug(
          f"Attempting to copy {str(response.path)} -> {str(local_path)}"
      )
      fs.get(str(response.path), str(local_path), recursive=False)
  
      # Ensure the file is properly written
      sleep(0.5)
  
      self._value = self.load(local_path)
      return self._value
  
imports: import hashlib
  import pathlib
  import pickle
  from abc import ABC, abstractmethod
  from time import sleep
  from typing import TYPE_CHECKING, Any, Optional, Union
  from lightning.app.core.constants import REMOTE_STORAGE_WAIT
  from lightning.app.core.queues import BaseQueue
  from lightning.app.storage.path import Path, _filesystem, _shared_storage_path
  from lightning.app.storage.requests import _ExistsRequest, _ExistsResponse, _GetRequest, _GetResponse
  from lightning.app.utilities.app_helpers import Logger
  from lightning.app.utilities.component import _is_flow_context
label_desc: Use image node_id 14 for calling the _BasePayload obj's underlying member method code with example usage: obj.get() and returns: self