modify topic transfer

trans2es/management/commands/trans2es_data2es_parallel.py

@@ -116,8 +116,10 @@ class Command(BaseCommand):
             type_info = get_type_info_map()[type_name]
             query_set = type_info.queryset
 
+            logging.info("before TableSlicer")
             slicer = TableSlicer(queryset=query_set, chunk_size=type_info.bulk_insert_chunk_size)
             for chunk in slicer.chunks():
+                logging.info("in chunks....")
                 job = Job(
                     sub_index_name=type_name,
                     type_name=type_name,

trans2es/models/topic.py

 #!/usr/bin/env python
 # -*- coding: utf-8 -*-
+from __future__ import unicode_literals, absolute_import, print_function
 
 from django.conf import settings
 from django.core.management.base import BaseCommand, CommandError