Git-Mirrors/brozzler
1
0
Fork 0
mirror of https://github.com/internetarchive/brozzler.git synced 2025-09-13 01:11:41 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

update rethinkdb imports

Browse source
This commit is contained in:
Barbara Miller 2023-10-17 14:58:34 -07:00
parent 8c32c98431
commit d07cee8cf0
5 changed files with 15 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

4
brozzler/cli.py
View file

@ -37,7 +37,9 @@ import warnings
import yaml
import shutil
import base64
import rethinkdb as r
import rethinkdb as rdb
r = rdb.RethinkDB()
def add_common_options(arg_parser, argv=None):
argv = argv or sys.argv

4
brozzler/dashboard/__init__.py
View file

@ -31,10 +31,12 @@ import doublethink
import json
import os
import importlib
import rethinkdb as r
import rethinkdb as rdb
import yaml
import base64
r = rdb.RethinkDB()
app = flask.Flask(__name__)
# configure with environment variables

4
brozzler/frontier.py
View file

@ -21,10 +21,12 @@ import brozzler
import random
import time
import datetime
import rethinkdb as r
import rethinkdb as rdb
import doublethink
import urlcanon
r = rdb.RethinkDB()
class UnexpectedDbResult(Exception):
pass

4
brozzler/pywb.py
View file

@ -35,12 +35,14 @@ except ImportError as e:
type(e).__name__, e)
sys.exit(1)
import doublethink
import rethinkdb as r
import rethinkdb as rdb
import urlcanon
import json
import brozzler
import argparse
r = rdb.RethinkDB()
class RethinkCDXSource(pywb.cdx.cdxsource.CDXSource):
def __init__(self, servers, db, table):
self.servers = servers

4
brozzler/worker.py
View file

@ -34,9 +34,11 @@ import doublethink
import tempfile
import urlcanon
from requests.structures import CaseInsensitiveDict
import rethinkdb as r
import rethinkdb as rdb
from . import ydl
r = rdb.RethinkDB()
class BrozzlerWorker:
logger = logging.getLogger(__module__ + "." + __qualname__)