#NEWLINE# def create_worker_fetcher( settings , mgmt , zmq_context , log_handler , io_loop ) : #NEWLINE# #INDENT# '\n    Create and return a new `Worker Fetcher`.\n    ' #NEWLINE# pulling_socket = zmq_context . socket ( zmq . PULL ) #NEWLINE# pulling_socket . connect ( settings . ZEROMQ_WORKER_PROC_FETCHER_PULL ) #NEWLINE# pushing_socket = zmq_context . socket ( zmq . PUSH ) #NEWLINE# pushing_socket . setsockopt ( zmq . HWM , settings . ZEROMQ_WORKER_PROC_FETCHER_PUSH_HWM ) #NEWLINE# pushing_socket . bind ( settings . ZEROMQ_WORKER_PROC_FETCHER_PUSH ) #NEWLINE# fetcher = FetchProcessor ( settings , fetcher ) #NEWLINE# return AsyncZmqWorker ( pulling_socket , pushing_socket , mgmt , fetcher , log_handler , settings . LOG_LEVEL_WORKER , io_loop )