code: def assert_failed_runs(failed_runs: int) -> None:
      cached_entry_metadata = get_response_metadata(
          kind=STEP_DA, dataset=DATASET_NAME
      )
      assert cached_entry_metadata is not None
      assert cached_entry_metadata["failed_runs"] == failed_runs
      assert CachedResponseDocument.objects().count() == 1
  
imports: from http import HTTPStatus
  import pytest
  from libcommon.constants import DEFAULT_DIFFICULTY_MAX, DIFFICULTY_BONUS_BY_FAILED_RUNS
  from libcommon.orchestrator import AfterJobPlan, finish_job, has_pending_ancestor_jobs, remove_dataset, set_revision
  from libcommon.processing_graph import Artifact, ProcessingGraph
  from libcommon.queue import JobDocument, Queue
  from libcommon.resources import CacheMongoResource, QueueMongoResource
  from libcommon.simple_cache import CachedResponseDocument, get_response_metadata, has_some_cache, upsert_response_params
  from libcommon.utils import JobOutput, JobResult, Priority, Status
  from .utils import ARTIFACT_CA_1, ARTIFACT_CA_2, ARTIFACT_DA, ARTIFACT_DB, ARTIFACT_DC, ARTIFACT_DD, ARTIFACT_DE, ARTIFACT_DG, ARTIFACT_DH, CONFIG_NAMES_CONTENT, DATASET_NAME, DIFFICULTY, JOB_RUNNER_VERSION, PROCESSING_GRAPH_FAN_IN_OUT, PROCESSING_GRAPH_GENEALOGY, PROCESSING_GRAPH_ONE_STEP, PROCESSING_GRAPH_PARALLEL, REVISION_NAME, STEP_CB, STEP_DA, STEP_DC, STEP_DD, artifact_id_to_job_info
label_desc: Use image node_id 11 for calling a global function with example usage: assert_failed_runs(failed_runs) without return types