Pathogen
/
monolith
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Implement indexing into Apache Druid #1

Closed
m wants to merge 263 commits from druid into master
pull from: druid
merge into: Pathogen:master
Conversation 1 Commits 263 Files Changed 128 +4 -4
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 7485bbefd1 - Show all commits

8
modules/userinfo.py
View File

@ -3,7 +3,7 @@ from string import digits
import main import main
from utils.logging.log import * from utils.logging.log import *
from utils.logging.debug import debug from utils.logging.debug import debug, trace
from utils.parsing import parsen from utils.parsing import parsen
def getWhoSingle(name, query): def getWhoSingle(name, query):
@ -84,7 +84,7 @@ def _initialUsers(name, channel, users):
p.execute() p.execute()
def initialUsers(name, channel, users): def initialUsers(name, channel, users):
debug("Initialising WHO records for %s on %s" % (channel, name)) trace("Initialising WHO records for %s on %s" % (channel, name))
d = deferToThread(_initialUsers, name, channel, users) d = deferToThread(_initialUsers, name, channel, users)
#d.addCallback(testCallback) #d.addCallback(testCallback)
@ -99,7 +99,7 @@ def _initialNames(name, channel, names):
p.execute() p.execute()
def initialNames(name, channel, names): def initialNames(name, channel, names):
debug("Initialising NAMES records for %s on %s" % (channel, name)) trace("Initialising NAMES records for %s on %s" % (channel, name))
d = deferToThread(_initialNames, name, channel, names) d = deferToThread(_initialNames, name, channel, names)
#d.addCallback(testCallback) #d.addCallback(testCallback)
@ -235,6 +235,6 @@ def _delChannels(net, channels):
p.execute() p.execute()
def delChannels(net, channels): # we have left a channel def delChannels(net, channels): # we have left a channel
debug("Purging channel %s for %s" % (", ".join(channels), net)) trace("Purging channel %s for %s" % (", ".join(channels), net))
d = deferToThread(_delChannels, net, channels) d = deferToThread(_delChannels, net, channels)
#d.addCallback(testCallback) #d.addCallback(testCallback)