Commit d73bcdff authored by lixiaofang's avatar lixiaofang

update trans2es_data2es_parallel.py

parent 9e9a9dfa
......@@ -106,11 +106,14 @@ class Command(BaseCommand):
type_info = get_type_info_map()[type_name]
query_set = type_info.queryset
import pdb
pdb.set_trace()
logging.info("query_set:%s" % query_set)
slicer = TableSlicer(queryset=query_set, chunk_size=type_info.bulk_insert_chunk_size)
for chunk in slicer.chunks():
job = Job(
sub_index_name=type_name,
......
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