code: def test_remove_dataset() -> None:
      Queue().create_jobs(
          [
              artifact_id_to_job_info(artifact)
              for artifact in [ARTIFACT_DA, ARTIFACT_DB]
          ]
      )
      Queue().start_job()
      job_info = artifact_id_to_job_info(ARTIFACT_DA)
      upsert_response_params(
          # inputs
          kind=STEP_DA,
          job_params=job_info["params"],
          job_runner_version=JOB_RUNNER_VERSION,
          # output
          content=CONFIG_NAMES_CONTENT,
          http_status=HTTPStatus.OK,
          error_code=None,
          details=None,
          progress=1.0,
      )
  
      pending_jobs_df = Queue().get_pending_jobs_df(
          dataset=DATASET_NAME
      )
      assert len(pending_jobs_df) > 0
      assert has_some_cache(dataset=DATASET_NAME) is True
  
      remove_dataset(dataset=DATASET_NAME)
  
      pending_jobs_df = Queue().get_pending_jobs_df(
          dataset=DATASET_NAME
      )
      assert len(pending_jobs_df) == 0
      assert has_some_cache(dataset=DATASET_NAME) is False
  
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 9 for calling a global function with example usage: test_remove_dataset() without return types