de37b10f2cbe01bee7baedbab37f485a6e7246aa,deepvariant/docker/gcp_deepvariant_runner.py,,_run_make_examples,#Any#,193

Before Change

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


def _run_call_variants(pipeline_args):
  Runs the call_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_call_variants(pipeline_args):
  Runs the call_variants job.
  num_workers = min(pipeline_args.call_variants_workers, pipeline_args.shards)
  shards_per_worker = pipeline_args.shards / num_workers

Instances