code: def _create_mount_drive_spec(
      work_name: str, mount: "Mount"
  ) -> V1LightningworkDrives:
      if mount.protocol == "s3://":
          drive_type = V1DriveType.INDEXED_S3
          source_type = V1SourceType.S3
      else:
          raise RuntimeError(
              f"unknown mounts protocol `{mount.protocol}`. Please verify this "
              f"drive type has been configured for use in the cloud dispatcher."
          )
  
      return V1LightningworkDrives(
          drive=V1Drive(
              metadata=V1Metadata(
                  name=work_name,
              ),
              spec=V1DriveSpec(
                  drive_type=drive_type,
                  source_type=source_type,
                  source=mount.source,
              ),
              status=V1DriveStatus(),
          ),
          mount_location=str(mount.mount_path),
      )
  
imports: import inspect
  import json
  import logging
  import os
  import random
  import string
  import urllib
  from time import monotonic, sleep, time
  from typing import List, Optional
  from lightning_cloud.openapi import AppinstancesIdBody, Externalv1LightningappInstance, Externalv1Lightningwork, V1BuildSpec, V1Drive, V1DriveSpec, V1DriveStatus, V1DriveType, V1Flowserver, V1LightningappInstanceState, V1LightningappRestartPolicy, V1LightningworkClusterDriver, V1LightningworkDrives, V1LightningworkSpec, V1LightningworkState, V1ListLightningworkResponse, V1Metadata, V1NetworkConfig, V1PackageManager, V1PythonDependencyInfo, V1SourceType, V1UserRequestedComputeConfig
  from lightning_cloud.openapi.rest import ApiException
  from lightning.app.core import LightningApp, LightningWork
  from lightning.app.core.queues import QueuingSystem
  from lightning.app.runners.backends.backend import Backend
  from lightning.app.storage import Drive, Mount
  from lightning.app.utilities.enum import WorkStageStatus, WorkStopReasons, make_status
  from lightning.app.utilities.exceptions import LightningPlatformException
  from lightning.app.utilities.network import LightningClient, _check_service_url_is_ready
  from lightning_cloud.openapi import SpecLightningappInstanceIdWorksBody, WorksIdBody
label_desc: Use image node_id 2 for calling a global function with example usage: _create_mount_drive_spec(work_name, mount) and returns: V1LightningworkDrives