def test_jt_configuration(cluster):
 err = validate_port(cluster.JT_THRIFT_PORT)
 if err:
  return err
 try:
  jt = LiveJobTracker.from_conf(cluster)
  jt.runtime_info()
 except TTransport.TTransportException:
  msg = ('Failed to contact JobTracker plugin at %s:%s.' % (cluster.HOST.get(), cluster.JT_THRIFT_PORT.get()))
  return [(cluster, msg)]
 return []

def test_jt_configuration ( cluster ) : err = validate_port ( cluster . JT_THRIFT_PORT ) if err : return err try : jt = LiveJobTracker . from_conf ( cluster ) jt . runtime_info ( ) except TTransport . TTransportException : msg = ( 'Failed to contact JobTracker plugin at %s:%s.' % ( cluster . HOST . get ( ) , cluster . JT_THRIFT_PORT . get ( ) ) ) return [ ( cluster , msg ) ] return [ ]
test fs configuration .