Skip to content

Commit

Permalink
Fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
lalinsky committed Oct 19, 2012
1 parent 7d89303 commit 13a2c00
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 3 deletions.
2 changes: 1 addition & 1 deletion acoustid/script.py
Expand Up @@ -5,7 +5,7 @@
import logging
import sqlalchemy
import sqlalchemy.pool
import redis
from redis import Redis
from optparse import OptionParser
from acoustid.config import Config
from acoustid.indexclient import IndexClientPool
Expand Down
5 changes: 3 additions & 2 deletions scripts/import_submissions.py
Expand Up @@ -4,17 +4,18 @@
# Distributed under the MIT license, see the LICENSE file for details.

import json
import logging
from acoustid.script import run_script
from acoustid.data.submission import import_queued_submissions

logger = logging.getLogger(__name__)
logger = logging.getLogger(__file__)


def main(script, opts, args):
channel = script.redis.pubsub()
channel.subscribe('channel.submissions')
for message in channel.listen():
ids = json.loads(message)
ids = json.loads(message['data'])
logger.debug('Got notified about %s new submissions', len(ids))
#conn = script.engine.connect()
#import_queued_submissions(conn, limit=300, index=script.index)
Expand Down

0 comments on commit 13a2c00

Please sign in to comment.