code: def memory_monitor_running(dask_worker: Worker | Nanny) -> bool:
      return "memory_monitor" in dask_worker.periodic_callbacks
  
imports: from __future__ import annotations
  import asyncio
  import glob
  import logging
  import os
  import signal
  from collections import Counter, UserDict
  from time import sleep
  import psutil
  import pytest
  from tlz import merge
  import dask.config
  from dask.utils import format_bytes, parse_bytes
  import distributed.system
  from distributed import Client, Event, KilledWorker, Nanny, Scheduler, Worker, wait
  from distributed.compatibility import MACOS, WINDOWS
  from distributed.core import Status
  from distributed.metrics import monotonic
  from distributed.utils import RateLimiterFilter
  from distributed.utils_test import NO_AMM, async_poll_for, captured_logger, gen_cluster, inc, wait_for_state
  from distributed.worker_memory import parse_memory_limit
  from distributed.worker_state_machine import ComputeTaskEvent, ExecuteSuccessEvent, GatherDep, GatherDepSuccessEvent, TaskErredMsg
label_desc: Use image node_id 1 for calling a global function with example usage: memory_monitor_running(dask_worker) and returns: unknown