def METHOD_NAME(
    client_id: Text,
    flow_id: Text,
) -> api_call_handler_base.ApiBinaryStream:
  filename = f"osquery_{flow_id}.csv"
  results = _FetchOsqueryResults(client_id=client_id, flow_id=flow_id)
  content = _ParseToCsvBytes(results)
  return api_call_handler_base.ApiBinaryStream(filename, content)