#NEWLINE# def is_service_runner( self ) : #NEWLINE# #INDENT# 'True if pipeline will execute on the Google Cloud Dataflow service.' #NEWLINE# is_service_runner = ( ( self . runner is not None ) and ( type ( self . runner ) . __name__ in [ 'DataflowPipelineRunner' , 'BlockingDataflowPipelineRunner' ] ) ) #NEWLINE# dataflow_endpoint = self . options . view_as ( GoogleCloudOptions ) . dataflow_endpoint #NEWLINE# is_service_endpoint = ( ( dataflow_endpoint is not None ) and self . is_full_string_match ( self . ENDPOINT_PATTERN , dataflow_endpoint ) ) #NEWLINE# return ( is_service_runner and is_service_endpoint )