def test_repo_fs(client, repository=None):
 try:
  nodes = client.snapshot.verify_repository(repository=repository)['nodes']
  logger.debug('All nodes can write to the repository')
  logger.debug('Nodes with verified repository access: {0}'.format(nodes))
 except Exception as e:
  try:
   if (e.status_code == 404):
    msg = '--- Repository "{0}" not found. Error: {1}, {2}'.format(repository, e.status_code, e.error)
   else:
    msg = '--- Got a {0} response from Elasticsearch.  Error message: {1}'.format(e.status_code, e.error)
  except AttributeError:
   msg = '--- Error message: {0}'.format(e)
  raise ActionError('Failed to verify all nodes have repository access: {0}'.format(msg))

def test_repo_fs ( client , repository = None ) : try : nodes = client . snapshot . verify_repository ( repository = repository ) [ 'nodes' ] logger . debug ( 'All nodes can write to the repository' ) logger . debug ( 'Nodes with verified repository access: {0}' . format ( nodes ) ) except Exception as e : try : if ( e . status_code == 404 ) : msg = '--- Repository "{0}" not found. Error: {1}, {2}' . format ( repository , e . status_code , e . error ) else : msg = '--- Got a {0} response from Elasticsearch.  Error message: {1}' . format ( e . status_code , e . error ) except AttributeError : msg = '--- Error message: {0}' . format ( e ) raise ActionError ( 'Failed to verify all nodes have repository access: {0}' . format ( msg ) )
test whether all nodes have write access to the repository :arg client: an :class:elasticsearch .