#NEWLINE# @ LoggedACL ( 'can_start_flow' ) #NEWLINE# @ stats . Timed ( 'acl_check_time' , fields = [ 'data_store_access' ] ) #NEWLINE# def CheckDataStoreAccess( self , token , subjects , requested_access = 'r' ) : #NEWLINE# #INDENT# 'Allow all access if token and requested access are valid.' #NEWLINE# if any ( ( ( not x ) for x in subjects ) ) : #NEWLINE# #INDENT# raise ValueError ( "Subjects list can't contain empty URNs." ) #NEWLINE# #UNINDENT# subjects = map ( rdfvalue . RDFURN , self ) #NEWLINE# return ( ValidateAccessAndSubjects ( requested_access , subjects ) and ValidateToken ( token , subjects ) and ( token . supervisor or self . _CheckAccessWithHelpers ( token , subjects , requested_access ) ) )