Commit 9e9a9dfa authored by lixiaofang's avatar lixiaofang

update face

parent 36c917dd
...@@ -107,13 +107,11 @@ class Command(BaseCommand): ...@@ -107,13 +107,11 @@ class Command(BaseCommand):
query_set = type_info.queryset query_set = type_info.queryset
logging.info("query_set:%s"%query_set) logging.info("query_set:%s" % query_set)
slicer = TableSlicer(queryset=query_set, chunk_size=type_info.bulk_insert_chunk_size) slicer = TableSlicer(queryset=query_set, chunk_size=type_info.bulk_insert_chunk_size)
for chunk in slicer.chunks(): for chunk in slicer.chunks():
job = Job( job = Job(
sub_index_name=type_name, sub_index_name=type_name,
type_name=type_name, type_name=type_name,
......
...@@ -3,15 +3,12 @@ ...@@ -3,15 +3,12 @@
# from django.conf import settings # from django.conf import settings
# from django.core.management.base import BaseCommand, CommandError # from django.core.management.base import BaseCommand, CommandError
# import traceback import traceback
# import logging import logging
from django.db import models from django.db import models
import datetime import datetime
from django.db.models import QuerySet from django.db.models import QuerySet
from .topic import Topic
# from .topic import Topic
# manager = lambda: models.Manager().db_manager(using='face') # manager = lambda: models.Manager().db_manager(using='face')
......
...@@ -68,7 +68,7 @@ class TypeInfo(object): ...@@ -68,7 +68,7 @@ class TypeInfo(object):
@property @property
def queryset(self): def queryset(self):
return django.db.models.QuerySet(model=self.model, query=self.query).using("face") return django.db.models.QuerySet(model=self.model, query=self.query)
@property @property
def pk_blacklist(self): def pk_blacklist(self):
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment