Lines Matching refs:host_objects
289 def check_job_dependencies(host_objects, job_dependencies): argument
296 host_ids = [host.id for host in host_objects]
314 failing_hosts = (set(host.hostname for host in host_objects) -
482 def check_for_duplicate_hosts(host_objects): argument
483 host_counts = collections.Counter(host_objects)
494 def create_new_job(owner, options, host_objects, metahost_objects): argument
495 all_host_objects = host_objects + metahost_objects
505 check_for_duplicate_hosts(host_objects)
515 check_job_dependencies(host_objects, dependencies)
791 host_objects = models.Host.smart_get_bulk(hosts)
792 _validate_host_job_sharding(host_objects)
795 host_objects.append(this_host)
831 host_objects=host_objects,
835 def _validate_host_job_sharding(host_objects): argument
838 or _allowed_hosts_for_main_job(host_objects)):
839 shard_host_map = bucket_hosts_by_shard(host_objects)
846 def _allowed_hosts_for_main_job(host_objects): argument
853 shard_host_map = bucket_hosts_by_shard(host_objects)
859 assert len(hosts_on_shard) <= len(host_objects)
860 return len(hosts_on_shard) == len(host_objects)