Lines Matching refs:shard_hostname
138 def create_shard(cls, shard_hostname):
141 @param shard_hostname: The hostname of the shard.
143 shard = cls.get_shard(hostname=shard_hostname)
144 return (models.Shard.objects.create(hostname=shard_hostname)
172 def assign_job_to_shard(cls, job_id, shard_hostname):
176 @param shard_hostname: The hostname of a shard to assign the job.
183 job_filter, shard_hostname)
184 job_filter.update(shard=cls.create_shard(shard_hostname))
382 priority=0, parent_job_id=None, shard_hostname=None):
410 if shard_hostname:
411 self.db_helper.assign_job_to_shard(job.id, shard_hostname)
