Changeset View

Standalone View

Show First 20 Lines • Show All 243 Lines • ▼ Show 20 Lines	async def prepare_response(self):
src=[src],		src=[src],
edges=self.get_edges(),		edges=self.get_edges(),
direction=self.get_direction(),		direction=self.get_direction(),
return_nodes=NodeFilter(types=self.get_return_types()),		return_nodes=NodeFilter(types=self.get_return_types()),
mask=FieldMask(paths=["swhid"]),		mask=FieldMask(paths=["swhid"]),
)		)
if self.get_max_edges():		if self.get_max_edges():
self.traversal_request.max_edges = self.get_max_edges()		self.traversal_request.max_edges = self.get_max_edges()
		if self.get_limit():
		self.traversal_request.max_matches = self.get_limit()
await self.check_swhid(src)		await self.check_swhid(src)
self.configure_request()		self.configure_request()
self.nodes_stream = self.rpc_client.Traverse(self.traversal_request)		self.nodes_stream = self.rpc_client.Traverse(self.traversal_request)

# Force gRPC to query the server and fetch the first nodes; so errors		# Force gRPC to query the server and fetch the first nodes; so errors
# are raised early, so we can return HTTP 503 before HTTP 200		# are raised early, so we can return HTTP 503 before HTTP 200
await self.nodes_stream.wait_for_connection()		await self.nodes_stream.wait_for_connection()

▲ Show 20 Lines • Show All 106 Lines • Show Last 20 Lines