Lines Matching refs:shard
116 pool.run(('test_list', shard.name, shard.test_inputs) for shard in all_shards)
387 """A test shard is a named list of TestInputs."""
428 This is used when there's only one worker, to minimize the per-shard overhead."""
447 """Returns two lists of shards, each shard containing a single test file.
453 # Note that we use a '.' for the shard name; the name doesn't really
464 """Returns two lists of shards, each shard containing all the files in a directory.
480 shard = TestShard(directory, test_inputs)
482 locked_shards.append(shard)
486 unlocked_slow_shards.append(shard)
488 unlocked_shards.append(shard)
491 locked_shards.sort(key=lambda shard: shard.name)
492 unlocked_slow_shards.sort(key=lambda shard: shard.name)
493 unlocked_shards.sort(key=lambda shard: shard.name)
498 # FIXME: For now, limit to one shard or set it
510 # This implementation assumes that each input shard only contains tests from a
511 # single directory, and that tests in each shard must remain together; as a
512 # result, a given input shard is never split between output shards.
514 # Each output shard contains the tests from one or more input shards and
522 for shard in shards:
523 test_inputs.extend(shard.test_inputs)
