code: def test_compute(
      app_config: AppConfig,
      get_job_runner: GetJobRunner,
      upstream_responses: list[UpstreamResponse],
      expected: Any,
  ) -> None:
      dataset = DATASET
      upsert_response(**UPSTREAM_RESPONSE_CONFIG_NAMES)
      for upstream_response in upstream_responses:
          upsert_response(**upstream_response)
      job_runner = get_job_runner(dataset, app_config)
      compute_result = job_runner.compute()
      assert compute_result.content == expected[0]
      assert compute_result.progress == expected[1]
  
file_path: datasets-server/services/worker/tests/job_runners/dataset/test_is_valid.py
imports: from collections.abc import Callable
  from http import HTTPStatus
  from typing import Any
  import pytest
  from libcommon.resources import CacheMongoResource, QueueMongoResource
  from libcommon.simple_cache import upsert_response
  from libcommon.utils import Priority
  from worker.config import AppConfig
  from worker.job_runners.dataset.is_valid import DatasetIsValidJobRunner
  from ..utils import REVISION_NAME, UpstreamResponse
label_desc: Use image node_id 3 for calling a global function with example usage: test_compute(app_config, get_job_runner, upstream_responses, expected) without return types