code: def _get_spark_worker_total_physical_memory():
      import psutil
  
      if RAY_ON_SPARK_WORKER_PHYSICAL_MEMORY_BYTES in os.environ:
          return int(
              os.environ[RAY_ON_SPARK_WORKER_PHYSICAL_MEMORY_BYTES]
          )
      return psutil.virtual_memory().total
  
imports: import subprocess
  import os
  import sys
  import random
  import threading
  import collections
  import logging
  import time
label_desc: Use image node_id 10 for calling a global function with example usage: _get_spark_worker_total_physical_memory() and returns: psutil, int