mirror of
https://github.com/wassname/catalyst.git
synced 2026-07-03 10:51:22 +08:00
Updated refs.
This commit is contained in:
@@ -1,8 +1,8 @@
|
||||
import zmq
|
||||
import time
|
||||
import gevent
|
||||
import itertools
|
||||
# pyzmq
|
||||
import zmq
|
||||
import logging
|
||||
import gevent_zeromq
|
||||
|
||||
from collections import OrderedDict
|
||||
@@ -159,7 +159,7 @@ class Controller(object):
|
||||
debug = False
|
||||
period = 1
|
||||
|
||||
def __init__(self, pub_socket, route_socket, logging = None):
|
||||
def __init__(self, pub_socket, route_socket, logger = None):
|
||||
|
||||
self.context = None
|
||||
self.zmq = None
|
||||
@@ -182,11 +182,11 @@ class Controller(object):
|
||||
|
||||
self.error_replay = OrderedDict()
|
||||
|
||||
if logging:
|
||||
self.logging = logging
|
||||
if logger:
|
||||
self.logging = logger
|
||||
else:
|
||||
import util as qutil
|
||||
self.logging = qutil.LOGGER
|
||||
default_logger = logging.getLogger('ZiplineLogger')
|
||||
self.logging = default_logger
|
||||
|
||||
def init_zmq(self, flavor):
|
||||
|
||||
|
||||
@@ -6,7 +6,5 @@ and other common operations.
|
||||
import logging
|
||||
import logging.config
|
||||
|
||||
#logging.config.fileConfig('logging.cfg')
|
||||
|
||||
def configure_logginer():
|
||||
logging.config.fileConfig('logging.cfg')
|
||||
def configure_logging():
|
||||
logging.config.fileConfig('zipline_repo/logging.cfg')
|
||||
|
||||
Reference in New Issue
Block a user