def setup_polling(conf):
 cfg_file = conf.pipeline_cfg_file
 return PollingManager(conf, cfg_file)

def setup_polling ( conf ) : cfg_file = conf . pipeline_cfg_file return PollingManager ( conf , cfg_file )
setup polling manager according to yaml config file .