code: def _run_test(
      self,
      args=None,
      files={},
      jobfile=None,
      expected_results=None,
      **csargs,
  ):
      if not (any(csargs)):
          return
  
      jobfile = self.get_jobfile(
          jobfile or "completion_service_testfunc.py"
      )
  
      args = args or [0, 1]
  
      expected_results = expected_results or args
      submission_indices = {}
      n_experiments = len(args)
      experimentId = str(uuid.uuid4())
  
      with CompletionService(experimentId, **csargs) as cs:
          for i in range(0, n_experiments):
              key = cs.submitTaskWithFiles(jobfile, args[i], files)
              submission_indices[key] = i
  
          for i in range(0, n_experiments):
              result = cs.getResults(blocking=True)
              self.assertEquals(
                  result[1],
                  expected_results[submission_indices[result[0]]],
              )
  
imports: import uuid
  import random
  import unittest
  import os
  import hashlib
  import six
  import tempfile
  from timeout_decorator import timeout
  from .completion_service import CompletionService
  from studio.extra_util import has_aws_credentials
  from studio.util.util import rand_string, filehash
  from studio.storage.storage_util import download_file
label_desc: Use image node_id 1 for calling the CompletionServiceTest obj's underlying member method code with example usage: obj._run_test(args, files, jobfile, expected_results) without return types