de37b10f2cbe01bee7baedbab37f485a6e7246aa,deepvariant/docker/gcp_deepvariant_runner.py,,_run_call_variants,#Any#,243

Before Change

  threads.close()
  threads.join()
  // Ensure exceptions are re-thrown.
  _ = [result.get() for result in results if result]


def _run_postprocess_variants(pipeline_args):
  Runs the postprocess_variants job.

After Change

  threads.join()
  // Ensure exceptions are re-thrown (ignore socket.timeout errors from dstat
  // calls).
  for result in results:
    if result:
      try:
        result.get()
      except socket.timeout:
        logging.warning("Ignoring socket timeout exception.")


def _run_postprocess_variants(pipeline_args):
  Runs the postprocess_variants job.
  dsub_args = _get_base_job_args(pipeline_args) + [
      "--name",

Instances