stop_service.py

dag = DAG(config=config)                                                                      
                                                                                                   
                                                                                                   
class DAGService(service.Service):                                                               
    def startService(self):                                                                        
        # Something here in the dag.run() ultimately calls 'reactor.stop()' if a fatal error is encountered.
        # This winds up raising ReactorNotRunning when it is called.
        dag.run()                                                                                  
                                                                                                   
# This will hold the services that combine to form DAG                                             
top_service = service.MultiService()                                                               
                                                                                                   
dag_service = DAGService()                                                                                   
dag_service.setServiceParent(top_service)                                                        
                                                                                                   
                                                                                                   
# The Mail Service receives incoming emails from DLP and processes them.                           
mail_service = make_mail_service(dag)                                                              
mail_service.setServiceParent(top_service)                                                         
                                                                                                   
                                                                                                   
application = service.Application('dag')                                                           
                                                                                                   
# This hooks the collection we made to the application                                             
top_service.setServiceParent(application)