Lines Matching refs:rpc_utils
24 from autotest_lib.frontend.afe import rpc_utils
124 @rpc_utils.route_rpc_to_master
262 return rpc_utils.create_job_common(name,
294 return rpc_utils.prepare_for_serialization(config_values)
370 return rpc_utils.prepare_for_serialization(job_info.get_history())
398 return rpc_utils.prepare_for_serialization(
456 shard_obj = rpc_utils.retrieve_shard(shard_hostname=shard_hostname)
457 rpc_utils.persist_records_sent_from_shard(shard_obj, jobs, hqes)
465 hosts, jobs, suite_keyvals = rpc_utils.find_records_for_shard(
481 serialized_shards = rpc_utils.prepare_rows_as_nested_dicts(shards, ())
529 shard = rpc_utils.retrieve_shard(shard_hostname=hostname)
576 @rpc_utils.route_rpc_to_master
591 @rpc_utils.route_rpc_to_master
600 @rpc_utils.route_rpc_to_master
610 @rpc_utils.route_rpc_to_master
695 return rpc_utils.prepare_for_serialization(test_objects)
